[jira] [Updated] (FLINK-35237) Allow Sink to Choose HashFunction in PrePartitionOperator

2024-05-12 Thread zhangdingxin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangdingxin updated FLINK-35237: - Fix Version/s: cdc-3.2.0 > Allow Sink to Choose HashFunction in PrePartitionOperator >

[jira] [Commented] (FLINK-35237) Allow Sink to Choose HashFunction in PrePartitionOperator

2024-05-10 Thread zhangdingxin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845267#comment-17845267 ] zhangdingxin commented on FLINK-35237: -- If the maintainers agree that this improvement is

[jira] [Updated] (FLINK-35237) Allow Sink to Choose HashFunction in PrePartitionOperato

2024-05-10 Thread zhangdingxin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangdingxin updated FLINK-35237: - Summary: Allow Sink to Choose HashFunction in PrePartitionOperato (was: Allow Sink to Choose

[jira] [Updated] (FLINK-35237) Allow Sink to Choose HashFunction in PrePartitionOperator

2024-05-10 Thread zhangdingxin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangdingxin updated FLINK-35237: - Summary: Allow Sink to Choose HashFunction in PrePartitionOperator (was: Allow Sink to Choose

[jira] [Updated] (FLINK-35237) Allow Sink to Choose HashFunction in PrePartitionOperator for Flink Sink Customization

2024-05-10 Thread zhangdingxin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangdingxin updated FLINK-35237: - Description: The {{PrePartitionOperator}} in its current implementation only supports a fixed

[jira] [Created] (FLINK-35237) Allow Custom HashFunction in PrePartitionOperator for Flink Sink Customization

2024-04-25 Thread zhangdingxin (Jira)
zhangdingxin created FLINK-35237: Summary: Allow Custom HashFunction in PrePartitionOperator for Flink Sink Customization Key: FLINK-35237 URL: https://issues.apache.org/jira/browse/FLINK-35237

[jira] [Comment Edited] (FLINK-35167) Introduce MaxCompute pipeline DataSink

2024-04-18 Thread zhangdingxin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838836#comment-17838836 ] zhangdingxin edited comment on FLINK-35167 at 4/19/24 2:22 AM: --- I'd like

[jira] [Updated] (FLINK-35167) Introduce MaxCompute pipeline DataSink

2024-04-18 Thread zhangdingxin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangdingxin updated FLINK-35167: - Labels: (was: Flink-CDC connector) > Introduce MaxCompute pipeline DataSink >

[jira] [Commented] (FLINK-35167) Introduce MaxCompute pipeline DataSink

2024-04-18 Thread zhangdingxin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838836#comment-17838836 ] zhangdingxin commented on FLINK-35167: -- I'd like to do it

[jira] [Updated] (FLINK-35167) Introduce MaxCompute pipeline DataSink

2024-04-18 Thread zhangdingxin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangdingxin updated FLINK-35167: - Summary: Introduce MaxCompute pipeline DataSink (was: [CDC] Introduce MaxCompute pipeline

[jira] [Created] (FLINK-35167) [CDC] Introduce MaxCompute pipeline DataSink

2024-04-18 Thread zhangdingxin (Jira)
zhangdingxin created FLINK-35167: Summary: [CDC] Introduce MaxCompute pipeline DataSink Key: FLINK-35167 URL: https://issues.apache.org/jira/browse/FLINK-35167 Project: Flink Issue Type: New