flink-cdc
flink-cdc copied to clipboard
[FLINK-35237] Allow Sink to Choose HashFunction in PrePartitionOperator
https://issues.apache.org/jira/browse/FLINK-35237