-
Notifications
You must be signed in to change notification settings - Fork 13.8k
[FLINK-27964][python] Support Cassandra connector in Python DataStream API #20120
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
|
||
private static final long serialVersionUID = 1L; | ||
|
||
public static Cluster.Builder clusterBuilder; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
public static Cluster.Builder clusterBuilder; | |
private final Cluster.Builder clusterBuilder; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@dianfu The Cluster.Builder cannot be serialized, I have update the implementation in buildCluster method, PTAL~
|
||
@staticmethod | ||
def fallthrough_retry_policy() -> 'RetryPolicy': | ||
""" |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Add LoggingRetryPolicy?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
public LoggingRetryPolicy(RetryPolicy policy) method has interface parameters: policy that can not be serialized. Do you have a better idea?
This PR is being marked as stale since it has not had any activity in the last 180 days. If you are having difficulty finding a reviewer, please reach out to the [community](https://flink.apache.org/what-is-flink/community/). If this PR is no longer valid or desired, please feel free to close it. If no activity occurs in the next 90 days, it will be automatically closed. |
This PR has been closed since it has not had any activity in 120 days. |
What is the purpose of the change
Support Cassandra connector in Python DataStream API.
Brief change log
ClusterBuilder
.Verifying this change
Does this pull request potentially affect one of the following parts:
@Public(Evolving)
: (yes / no)Documentation