[jira] [Commented] (FLINK-37118) Enhance flink cdc metrics

[ https://issues.apache.org/jira/browse/FLINK-37118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17917006#comment-17917006 ] ChaomingZhang commented on FLINK-37118: --- [~melin] What a nice feature! In my opini

[jira] [Comment Edited] (FLINK-37203) Support AltertableCommentEvent and AlterColumnCommentEvent.

[ https://issues.apache.org/jira/browse/FLINK-37203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916347#comment-17916347 ] ChaomingZhang edited comment on FLINK-37203 at 1/23/25 10:19 AM: -

[jira] [Commented] (FLINK-37203) Support AltertableCommentEvent and AlterColumnCommentEvent.

[ https://issues.apache.org/jira/browse/FLINK-37203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916347#comment-17916347 ] ChaomingZhang commented on FLINK-37203: --- I would like to improve this issue. > Su

[jira] [Comment Edited] (FLINK-35713) Add sink PARALLELISM for flink-cdc

[ https://issues.apache.org/jira/browse/FLINK-35713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916338#comment-17916338 ] ChaomingZhang edited comment on FLINK-35713 at 1/23/25 9:58 AM: --

[jira] [Commented] (FLINK-35713) Add sink PARALLELISM for flink-cdc

[ https://issues.apache.org/jira/browse/FLINK-35713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916338#comment-17916338 ] ChaomingZhang commented on FLINK-35713: --- [~Leonard] The related [PR|https://github

[jira] [Created] (FLINK-37204) Add missing StarRocks connector options for 1.2.10.

ChaomingZhang created FLINK-37204: - Summary: Add missing StarRocks connector options for 1.2.10. Key: FLINK-37204 URL: https://issues.apache.org/jira/browse/FLINK-37204 Project: Flink Issue T

[jira] [Commented] (FLINK-37122) NoSuchMethodError occurs when using flink 1.18.1.

[ https://issues.apache.org/jira/browse/FLINK-37122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913184#comment-17913184 ] ChaomingZhang commented on FLINK-37122: --- [~leonard] Fine, [PR 3859|https://github.

[jira] [Commented] (FLINK-36829) Add better validation of pipeline config

[ https://issues.apache.org/jira/browse/FLINK-36829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912857#comment-17912857 ] ChaomingZhang commented on FLINK-36829: --- I guess, this exception possibly occurs w

[jira] [Commented] (FLINK-37122) NoSuchMethodError occurs when using flink 1.18.1.

[ https://issues.apache.org/jira/browse/FLINK-37122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912846#comment-17912846 ] ChaomingZhang commented on FLINK-37122: --- A simple way to solve this is replace the

[jira] [Updated] (FLINK-37122) NoSuchMethodError occurs when using flink 1.18.1.

[ https://issues.apache.org/jira/browse/FLINK-37122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChaomingZhang updated FLINK-37122: -- Component/s: Flink CDC > NoSuchMethodError occurs when using flink 1.18.1. > -

[jira] [Created] (FLINK-37122) NoSuchMethodError occurs when using flink 1.18.1.

ChaomingZhang created FLINK-37122: - Summary: NoSuchMethodError occurs when using flink 1.18.1. Key: FLINK-37122 URL: https://issues.apache.org/jira/browse/FLINK-37122 Project: Flink Issue Typ

[jira] [Commented] (FLINK-37011) Improve get source field value by column name in PreTransformProcessor.

[ https://issues.apache.org/jira/browse/FLINK-37011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912775#comment-17912775 ] ChaomingZhang commented on FLINK-37011: --- [~Leonard] Please assign to me. > Improv

[jira] [Commented] (FLINK-37046) OceanBase CDC Support for DDL event handling, converted to Debezium JSON format.

[ https://issues.apache.org/jira/browse/FLINK-37046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912395#comment-17912395 ] ChaomingZhang commented on FLINK-37046: --- [~huzekang] I have no idea about if we sh

[jira] [Commented] (FLINK-36794) Mysql cdc and postgres cdc support table and database scenarios

[ https://issues.apache.org/jira/browse/FLINK-36794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17911030#comment-17911030 ] ChaomingZhang commented on FLINK-36794: --- [~linjc13] Flink mysql cdc have already s

[jira] [Commented] (FLINK-37042) Unify option names using kebab-case in MaxComputeDataSinkOptions

[ https://issues.apache.org/jira/browse/FLINK-37042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910939#comment-17910939 ] ChaomingZhang commented on FLINK-37042: --- @[~Leonard] > Unify option names using k

[jira] [Created] (FLINK-37042) Unify option names using kebab-case in MaxComputeDataSinkOptions

ChaomingZhang created FLINK-37042: - Summary: Unify option names using kebab-case in MaxComputeDataSinkOptions Key: FLINK-37042 URL: https://issues.apache.org/jira/browse/FLINK-37042 Project: Flink

[jira] [Created] (FLINK-37011) Improve get source field value by column name in PreTransformProcessor.

ChaomingZhang created FLINK-37011: - Summary: Improve get source field value by column name in PreTransformProcessor. Key: FLINK-37011 URL: https://issues.apache.org/jira/browse/FLINK-37011 Project: Fl

[jira] [Closed] (FLINK-36917) Add OceanBase DataSource to Flink CDC

[ https://issues.apache.org/jira/browse/FLINK-36917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChaomingZhang closed FLINK-36917. - Release Note: OceanBase highly recommend mysql cdc pipeline connector. Resolution: Abandone

[jira] [Commented] (FLINK-36917) Add OceanBase DataSource to Flink CDC

[ https://issues.apache.org/jira/browse/FLINK-36917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906298#comment-17906298 ] ChaomingZhang commented on FLINK-36917: --- [~leonard] Yes. > Add OceanBase DataSour

[jira] [Created] (FLINK-36917) Add OceanBase DataSource to Flink CDC

ChaomingZhang created FLINK-36917: - Summary: Add OceanBase DataSource to Flink CDC Key: FLINK-36917 URL: https://issues.apache.org/jira/browse/FLINK-36917 Project: Flink Issue Type: New Featu