[jira] [Assigned] (FLINK-38057) Connector emit time lag may be a wrong value

[ https://issues.apache.org/jira/browse/FLINK-38057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang reassigned FLINK-38057: - Assignee: Ruan Hang > Connector emit time lag may be a wrong value > --

[jira] [Created] (FLINK-38057) Connector emit time lag may be a wrong value

Ruan Hang created FLINK-38057: - Summary: Connector emit time lag may be a wrong value Key: FLINK-38057 URL: https://issues.apache.org/jira/browse/FLINK-38057 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-37905) Transform will throw exceptions when handling chinese characters

[ https://issues.apache.org/jira/browse/FLINK-37905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang reassigned FLINK-37905: - Assignee: yux > Transform will throw exceptions when handling chinese characters > ---

[jira] [Updated] (FLINK-37905) Transform will throw exceptions when handling chinese characters

[ https://issues.apache.org/jira/browse/FLINK-37905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-37905: -- Fix Version/s: cdc-3.5.0 > Transform will throw exceptions when handling chinese characters > ---

[jira] [Updated] (FLINK-37905) Transform will throw exceptions when handling chinese characters

[ https://issues.apache.org/jira/browse/FLINK-37905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-37905: -- Affects Version/s: cdc-3.4.0 > Transform will throw exceptions when handling chinese characters > ---

[jira] [Created] (FLINK-37905) Transform will throw exceptions when handling chinese characters

Ruan Hang created FLINK-37905: - Summary: Transform will throw exceptions when handling chinese characters Key: FLINK-37905 URL: https://issues.apache.org/jira/browse/FLINK-37905 Project: Flink

[jira] [Resolved] (FLINK-37509) Increment scan source no need to buffer data when enable skipping backfill.

[ https://issues.apache.org/jira/browse/FLINK-37509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang resolved FLINK-37509. --- Resolution: Fixed master(3.4-SNAPSHOT) : c9a273212ab04d7ce069c4b8eef8738b4c0079ca > Increment scan

[jira] [Updated] (FLINK-37100) Fix test_netty_shuffle_memory_control.sh with Netty4 RPC

[ https://issues.apache.org/jira/browse/FLINK-37100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-37100: -- Component/s: Tests > Fix test_netty_shuffle_memory_control.sh with Netty4 RPC > --

[jira] [Updated] (FLINK-37108) Source/Sink test suites test invalid recovery

[ https://issues.apache.org/jira/browse/FLINK-37108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-37108: -- Component/s: Tests > Source/Sink test suites test invalid recovery > -

[jira] [Updated] (FLINK-36812) The flink jdbc connector's 'scan.partition.column' supports the varchar field type.

[ https://issues.apache.org/jira/browse/FLINK-36812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-36812: -- Fix Version/s: jdbc-4.1.0 (was: jdbc-4.0.0) > The flink jdbc connector's 'scan.

[jira] [Updated] (FLINK-37305) JDBC Connector CI failed due to network issue

[ https://issues.apache.org/jira/browse/FLINK-37305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-37305: -- Fix Version/s: jdbc-4.1.0 (was: jdbc-4.0.0) > JDBC Connector CI failed due to n

[jira] [Updated] (FLINK-35811) Add the documentation sections to describe the usage of users-oriented interfaces

[ https://issues.apache.org/jira/browse/FLINK-35811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35811: -- Fix Version/s: jdbc-4.1.0 (was: jdbc-4.0.0) > Add the documentation sections to

[jira] [Updated] (FLINK-35363) FLIP-449: Reorganization of flink-connector-jdbc

[ https://issues.apache.org/jira/browse/FLINK-35363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35363: -- Fix Version/s: jdbc-4.1.0 (was: jdbc-4.0.0) > FLIP-449: Reorganization of flink

[jira] [Updated] (FLINK-30371) JdbcOutputFormat is at risk of database connection leaks

[ https://issues.apache.org/jira/browse/FLINK-30371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-30371: -- Fix Version/s: jdbc-4.1.0 (was: jdbc-4.0.0) > JdbcOutputFormat is at risk of da

[jira] [Updated] (FLINK-30371) JdbcOutputFormat is at risk of database connection leaks

[ https://issues.apache.org/jira/browse/FLINK-30371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-30371: -- Fix Version/s: jdbc-4.0.0 (was: jdbc-3.3.0) > JdbcOutputFormat is at risk of da

[jira] [Updated] (FLINK-35363) FLIP-449: Reorganization of flink-connector-jdbc

[ https://issues.apache.org/jira/browse/FLINK-35363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35363: -- Fix Version/s: jdbc-4.0.0 (was: jdbc-3.3.0) > FLIP-449: Reorganization of flink

[jira] [Commented] (FLINK-35811) Add the documentation sections to describe the usage of users-oriented interfaces

[ https://issues.apache.org/jira/browse/FLINK-35811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17942094#comment-17942094 ] Ruan Hang commented on FLINK-35811: --- This issue is not a blocker for jdbc-3.3.0. Move

[jira] [Updated] (FLINK-35811) Add the documentation sections to describe the usage of users-oriented interfaces

[ https://issues.apache.org/jira/browse/FLINK-35811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35811: -- Fix Version/s: jdbc-4.0.0 (was: jdbc-3.3.0) > Add the documentation sections to

[jira] [Resolved] (FLINK-37484) unbounded-chunk-first.enabled no use in unevenly chunk split

[ https://issues.apache.org/jira/browse/FLINK-37484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang resolved FLINK-37484. --- Resolution: Fixed master(3.4-SNAPSHOT): 164671558ad41751d8c250b37f3341afecbba413 > unbounded-chunk-

[jira] [Updated] (FLINK-36812) The flink jdbc connector's 'scan.partition.column' supports the varchar field type.

[ https://issues.apache.org/jira/browse/FLINK-36812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-36812: -- Fix Version/s: jdbc-4.0.0 (was: jdbc-3.3.0) > The flink jdbc connector's 'scan.

[jira] [Commented] (FLINK-35363) FLIP-449: Reorganization of flink-connector-jdbc

[ https://issues.apache.org/jira/browse/FLINK-35363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17942095#comment-17942095 ] Ruan Hang commented on FLINK-35363: --- This issue is not a blocker for jdbc-3.3.0. Move

[jira] [Commented] (FLINK-30371) JdbcOutputFormat is at risk of database connection leaks

[ https://issues.apache.org/jira/browse/FLINK-30371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17942096#comment-17942096 ] Ruan Hang commented on FLINK-30371: --- This issue is not a blocker for jdbc-3.3.0. Move

[jira] [Commented] (FLINK-36812) The flink jdbc connector's 'scan.partition.column' supports the varchar field type.

[ https://issues.apache.org/jira/browse/FLINK-36812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17942093#comment-17942093 ] Ruan Hang commented on FLINK-36812: --- This issue is not a blocker for jdbc-3.3.0. Move

[jira] [Commented] (FLINK-37305) JDBC Connector CI failed due to network issue

[ https://issues.apache.org/jira/browse/FLINK-37305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17942092#comment-17942092 ] Ruan Hang commented on FLINK-37305: --- This is not a block for jdbc-3.3.0, move it to a

[jira] [Updated] (FLINK-37305) JDBC Connector CI failed due to network issue

[ https://issues.apache.org/jira/browse/FLINK-37305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-37305: -- Fix Version/s: jdbc-4.0.0 (was: jdbc-3.3.0) > JDBC Connector CI failed due to n

[jira] [Assigned] (FLINK-37630) Support flink cdc pipeline Yarn session mode

[ https://issues.apache.org/jira/browse/FLINK-37630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang reassigned FLINK-37630: - Assignee: ouyangwulin > Support flink cdc pipeline Yarn session mode >

[jira] [Resolved] (FLINK-37000) MySQL CDC could not handle date and time data prior to unix epoch

[ https://issues.apache.org/jira/browse/FLINK-37000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang resolved FLINK-37000. --- Fix Version/s: cdc-3.4.0 Assignee: yux Resolution: Fixed master(3.4-SNAPSHOT) : 4bae

[jira] [Resolved] (FLINK-37529) Add flink-cdc-commom to the package to all the incremental source framework

[ https://issues.apache.org/jira/browse/FLINK-37529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang resolved FLINK-37529. --- Resolution: Fixed master(3.4-SNAPSHOT): d6f8bd4355e995a3f6f986b8f7fd51b8f6a6712b > Add flink-cdc-co

[jira] [Assigned] (FLINK-34820) [postgres] Remove unnecessary schema fresh to improve performance.

[ https://issues.apache.org/jira/browse/FLINK-34820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang reassigned FLINK-34820: - Assignee: ouyangwulin (was: ouyangwulin) > [postgres] Remove unnecessary schema fresh to impro

[jira] [Assigned] (FLINK-34820) [postgres] Remove unnecessary schema fresh to improve performance.

[ https://issues.apache.org/jira/browse/FLINK-34820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang reassigned FLINK-34820: - Assignee: ouyangwulin > [postgres] Remove unnecessary schema fresh to improve performance. > --

[jira] [Comment Edited] (FLINK-37233) Flink-CDC Documentation change request

[ https://issues.apache.org/jira/browse/FLINK-37233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923919#comment-17923919 ] Ruan Hang edited comment on FLINK-37233 at 2/5/25 6:14 AM: --- ma

[jira] [Resolved] (FLINK-37233) Flink-CDC Documentation change request

[ https://issues.apache.org/jira/browse/FLINK-37233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang resolved FLINK-37233. --- Fix Version/s: cdc-3.3.1 Resolution: Fixed > Flink-CDC Documentation change request > ---

[jira] [Updated] (FLINK-37233) Flink-CDC Documentation change request

[ https://issues.apache.org/jira/browse/FLINK-37233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-37233: -- Affects Version/s: (was: cdc-3.4.0) > Flink-CDC Documentation change request > ---

[jira] [Commented] (FLINK-37233) Flink-CDC Documentation change request

[ https://issues.apache.org/jira/browse/FLINK-37233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923919#comment-17923919 ] Ruan Hang commented on FLINK-37233: --- master(3.4-SNAPSHOT): aeebf674ba6a054a57a9ab08d34

[jira] [Assigned] (FLINK-37233) Flink-CDC Documentation change request

[ https://issues.apache.org/jira/browse/FLINK-37233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang reassigned FLINK-37233: - Assignee: qinghuan wang > Flink-CDC Documentation change request >

[jira] [Assigned] (FLINK-36852) Avoid StackOverflowError in Paimon Pipeline sink

[ https://issues.apache.org/jira/browse/FLINK-36852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang reassigned FLINK-36852: - Assignee: Yanquan Lv > Avoid StackOverflowError in Paimon Pipeline sink > -

[jira] [Resolved] (FLINK-36866) Support more CDC YAML numeric casting paths

[ https://issues.apache.org/jira/browse/FLINK-36866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang resolved FLINK-36866. --- Resolution: Fixed > Support more CDC YAML numeric casting paths > --

[jira] [Updated] (FLINK-34595) Fix ClassNotFoundException: com.ververica.cdc.common.utils.StringUtils

[ https://issues.apache.org/jira/browse/FLINK-34595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-34595: -- Affects Version/s: cdc-3.2.1 > Fix ClassNotFoundException: com.ververica.cdc.common.utils.StringUtils

[jira] [Commented] (FLINK-34595) Fix ClassNotFoundException: com.ververica.cdc.common.utils.StringUtils

[ https://issues.apache.org/jira/browse/FLINK-34595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916644#comment-17916644 ] Ruan Hang commented on FLINK-34595: --- [~kunni] This has been fixed via master(26eb6a99

[jira] [Closed] (FLINK-34595) Fix ClassNotFoundException: com.ververica.cdc.common.utils.StringUtils

[ https://issues.apache.org/jira/browse/FLINK-34595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang closed FLINK-34595. - Resolution: Fixed > Fix ClassNotFoundException: com.ververica.cdc.common.utils.StringUtils > ---

[jira] [Updated] (FLINK-37163) Add documents for recently merged PRs in FlinkCDC 3.3

[ https://issues.apache.org/jira/browse/FLINK-37163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-37163: -- Fix Version/s: cdc-3.3.1 (was: cdc-3.3.0) > Add documents for recently merged P

[jira] [Updated] (FLINK-37152) Update Flink version to 1.20 in Flink CDC

[ https://issues.apache.org/jira/browse/FLINK-37152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-37152: -- Fix Version/s: cdc-3.3.1 (was: cdc-3.3.0) > Update Flink version to 1.20 in Fli

[jira] [Updated] (FLINK-35234) Fix NullPointerException of org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString

[ https://issues.apache.org/jira/browse/FLINK-35234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35234: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.3.1) > Fix NullPointerException of > org.

[jira] [Resolved] (FLINK-35234) Fix NullPointerException of org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString

[ https://issues.apache.org/jira/browse/FLINK-35234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang resolved FLINK-35234. --- Resolution: Fixed > Fix NullPointerException of > org.apache.flink.cdc.common.configuration.Configu

[jira] [Updated] (FLINK-35234) Fix NullPointerException of org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString

[ https://issues.apache.org/jira/browse/FLINK-35234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35234: -- Fix Version/s: cdc-3.3.1 (was: cdc-3.3.0) > Fix NullPointerException of > org.

[jira] [Updated] (FLINK-35684) Add missing option for DataSource and DataSink

[ https://issues.apache.org/jira/browse/FLINK-35684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35684: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.1) > Add missing option for DataSource a

[jira] [Updated] (FLINK-35589) Support MemorySize type in FlinkCDC ConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-35589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35589: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > Support MemorySize type in FlinkCDC

[jira] [Updated] (FLINK-35684) Add missing option for DataSource and DataSink

[ https://issues.apache.org/jira/browse/FLINK-35684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35684: -- Fix Version/s: cdc-3.3.1 (was: cdc-3.3.0) > Add missing option for DataSource a

[jira] [Updated] (FLINK-35718) Cherrypick DBZ-5333 to fix frequently failover by EOFException.

[ https://issues.apache.org/jira/browse/FLINK-35718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35718: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > Cherrypick DBZ-5333 to fix frequent

[jira] [Updated] (FLINK-35888) Add e2e test for paimon DataSink

[ https://issues.apache.org/jira/browse/FLINK-35888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35888: -- Fix Version/s: cdc-3.3.1 (was: cdc-3.3.0) > Add e2e test for paimon DataSink >

[jira] [Updated] (FLINK-36827) [Docs] Tidy up Flink CDC Doris/MySQL quickstart page

[ https://issues.apache.org/jira/browse/FLINK-36827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-36827: -- Fix Version/s: cdc-3.3.1 (was: cdc-3.3.0) > [Docs] Tidy up Flink CDC Doris/MySQ

[jira] [Updated] (FLINK-35834) Update Doris Dependency to 1.6.2 to use group commit.

[ https://issues.apache.org/jira/browse/FLINK-35834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35834: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > Update Doris Dependency to 1.6.2 to

[jira] [Updated] (FLINK-35444) Paimon Pipeline Connector support changing column names to lowercase for Hive metastore

[ https://issues.apache.org/jira/browse/FLINK-35444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35444: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > Paimon Pipeline Connector support c

[jira] [Updated] (FLINK-35349) Use connection in openJdbcConnection of SqlServerDialect/Db2Dialect/OracleDialect

[ https://issues.apache.org/jira/browse/FLINK-35349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35349: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > Use connection in openJdbcConnectio

[jira] [Updated] (FLINK-36111) fix: adjust MultiTableCommittableChannelComputer Topology name

[ https://issues.apache.org/jira/browse/FLINK-36111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-36111: -- Fix Version/s: cdc-3.3.1 (was: cdc-3.3.0) > fix: adjust MultiTableCommittableCh

[jira] [Updated] (FLINK-36218) Documentations clean up before CDC 3.2.0 release

[ https://issues.apache.org/jira/browse/FLINK-36218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-36218: -- Fix Version/s: cdc-3.3.1 (was: cdc-3.3.0) > Documentations clean up before CDC

[jira] [Updated] (FLINK-35919) The rowkind keyword option for MySQL connector metadata should be changed to op_type keyword

[ https://issues.apache.org/jira/browse/FLINK-35919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35919: -- Fix Version/s: cdc-3.3.1 (was: cdc-3.3.0) > The rowkind keyword option for MySQ

[jira] [Updated] (FLINK-36220) Clean up typo and stale links in docs

[ https://issues.apache.org/jira/browse/FLINK-36220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-36220: -- Fix Version/s: cdc-3.3.1 (was: cdc-3.3.0) > Clean up typo and stale links in do

[jira] [Updated] (FLINK-35627) Avoid conflict when pipeline job that used Paimon as sink restart.

[ https://issues.apache.org/jira/browse/FLINK-35627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35627: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > Avoid conflict when pipeline job th

[jira] [Updated] (FLINK-34750) "legacy-flink-cdc-sources" Page of Postgresql for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-34750: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > "legacy-flink-cdc-sources" Page of

[jira] [Updated] (FLINK-35090) Doris sink fails to create table when database does not exist

[ https://issues.apache.org/jira/browse/FLINK-35090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35090: -- Fix Version/s: cdc-3.3.1 (was: cdc-3.3.0) > Doris sink fails to create table wh

[jira] [Updated] (FLINK-34904) [Feature] submit Flink CDC pipeline job to yarn application cluster.

[ https://issues.apache.org/jira/browse/FLINK-34904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-34904: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > [Feature] submit Flink CDC pipeline

[jira] [Updated] (FLINK-34752) "legacy-flink-cdc-sources" Page of TIDB for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-34752: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > "legacy-flink-cdc-sources" Page of

[jira] [Updated] (FLINK-34749) "legacy-flink-cdc-sources" Page of SQLServer for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-34749: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > "legacy-flink-cdc-sources" Page of

[jira] [Updated] (FLINK-36708) Optimize Table Collection Handling Logic to Improve Efficiency

[ https://issues.apache.org/jira/browse/FLINK-36708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-36708: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > Optimize Table Collection Handling

[jira] [Updated] (FLINK-35873) Add HashFunctionProvider for Paimon DataSink.

[ https://issues.apache.org/jira/browse/FLINK-35873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35873: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > Add HashFunctionProvider for Paimon

[jira] [Updated] (FLINK-34735) "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-34735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-34735: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > "Developer Guide - Understanding Fl

[jira] [Updated] (FLINK-34747) "legacy-flink-cdc-sources" Page of DB2 for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-34747: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > "legacy-flink-cdc-sources" Page of

[jira] [Updated] (FLINK-34736) "Deployment - Standalone" Page for Flink CDC Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-34736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-34736: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > "Deployment - Standalone" Page for

[jira] [Updated] (FLINK-34748) "legacy-flink-cdc-sources" Page of Oracle for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-34748: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > "legacy-flink-cdc-sources" Page of

[jira] [Updated] (FLINK-36566) Code optimization: always identify DataChangeEvent before SchemaChangeEvent in Operator

[ https://issues.apache.org/jira/browse/FLINK-36566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-36566: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > Code optimization: always identify

[jira] [Updated] (FLINK-35544) No description of Flink Operator in the Deployment of  Kubernetes document

[ https://issues.apache.org/jira/browse/FLINK-35544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35544: -- Fix Version/s: cdc-3.3.0 (was: cdc-3.3.1) > No description of Flink Operator in

[jira] [Updated] (FLINK-36263) Include only changed columns in old for canal format in Kakfa Sink

[ https://issues.apache.org/jira/browse/FLINK-36263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-36263: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > Include only changed columns in old

[jira] [Resolved] (FLINK-35544) No description of Flink Operator in the Deployment of  Kubernetes document

[ https://issues.apache.org/jira/browse/FLINK-35544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang resolved FLINK-35544. --- Resolution: Fixed > No description of Flink Operator in the Deployment of  Kubernetes document > ---

[jira] [Updated] (FLINK-34730) Translate pages of Flink CDC docs to Chinese

[ https://issues.apache.org/jira/browse/FLINK-34730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-34730: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.1) > Translate pages of Flink CDC docs t

[jira] [Updated] (FLINK-34730) Translate pages of Flink CDC docs to Chinese

[ https://issues.apache.org/jira/browse/FLINK-34730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-34730: -- Fix Version/s: cdc-3.3.1 (was: cdc-3.3.0) > Translate pages of Flink CDC docs t

[jira] [Updated] (FLINK-35544) No description of Flink Operator in the Deployment of  Kubernetes document

[ https://issues.apache.org/jira/browse/FLINK-35544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35544: -- Fix Version/s: cdc-3.3.1 (was: cdc-3.3.0) > No description of Flink Operator in

[jira] [Updated] (FLINK-36023) Flink CDC K8S Native Application Mode add wrong jar url.

[ https://issues.apache.org/jira/browse/FLINK-36023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-36023: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.4.0) > Flink CDC K8S Native Application Mo

[jira] [Resolved] (FLINK-36023) Flink CDC K8S Native Application Mode add wrong jar url.

[ https://issues.apache.org/jira/browse/FLINK-36023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang resolved FLINK-36023. --- Resolution: Fixed master(3.2-SNAOSHOT):5284df571feb91354248bf0ffac184b89d9db30c > Flink CDC K8S Nat

[jira] [Updated] (FLINK-36023) Flink CDC K8S Native Application Mode add wrong jar url.

[ https://issues.apache.org/jira/browse/FLINK-36023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-36023: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > Flink CDC K8S Native Application Mo

[jira] [Updated] (FLINK-36219) Add Flink compatibility matrix of CDC releases

[ https://issues.apache.org/jira/browse/FLINK-36219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-36219: -- Fix Version/s: cdc-3.3.1 (was: cdc-3.3.0) > Add Flink compatibility matrix of C

[jira] [Updated] (FLINK-36573) Add table information of binlog offsets when checkpointing

[ https://issues.apache.org/jira/browse/FLINK-36573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-36573: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) (was: cdc-3.2.1

[jira] [Updated] (FLINK-34467) Implement Lineage Interface in Jdbc Connector

[ https://issues.apache.org/jira/browse/FLINK-34467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-34467: -- Fix Version/s: (was: cdc-3.3.0) > Implement Lineage Interface in Jdbc Connector >

[jira] [Updated] (FLINK-35849) [flink-cdc] Use expose_snapshot to read snapshot splits of postgres cdc connector.

[ https://issues.apache.org/jira/browse/FLINK-35849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35849: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > [flink-cdc] Use expose_snapshot to

[jira] [Updated] (FLINK-36041) Eliminate Calcite dependency during runtime

[ https://issues.apache.org/jira/browse/FLINK-36041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-36041: -- Issue Type: Improvement (was: Technical Debt) > Eliminate Calcite dependency during runtime > ---

[jira] [Updated] (FLINK-36844) Postgres CDC document add mapping from postgres timestamp_tz to flink timestamp ltz

[ https://issues.apache.org/jira/browse/FLINK-36844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-36844: -- Fix Version/s: cdc-3.3.1 (was: cdc-3.3.0) > Postgres CDC document add mapping f

[jira] [Updated] (FLINK-36041) Eliminate Calcite dependency during runtime

[ https://issues.apache.org/jira/browse/FLINK-36041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-36041: -- Fix Version/s: cdc-3.3.1 (was: cdc-3.3.0) > Eliminate Calcite dependency during

[jira] [Updated] (FLINK-36546) Handle batch sources in DataSinkTranslator

[ https://issues.apache.org/jira/browse/FLINK-36546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-36546: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > Handle batch sources in DataSinkTra

[jira] [Updated] (FLINK-35671) Support Iceberg CDC Pipeline Sink

[ https://issues.apache.org/jira/browse/FLINK-35671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35671: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > Support Iceberg CDC Pipeline Sink >

[jira] [Updated] (FLINK-35173) Debezium for Mysql connector Custom Time Serializer

[ https://issues.apache.org/jira/browse/FLINK-35173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35173: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.1.0) (was: cdc-3.3.0

[jira] [Updated] (FLINK-35760) [docs] Add scan.newly-added-table.enabled to docs.

[ https://issues.apache.org/jira/browse/FLINK-35760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35760: -- Fix Version/s: cdc-3.3.1 (was: cdc-3.3.0) > [docs] Add scan.newly-added-table.e

[jira] [Updated] (FLINK-35693) Change variable specificOffsetFile, specificOffsetPos and startupTimestampMillis to Offset in StartupOptions

[ https://issues.apache.org/jira/browse/FLINK-35693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35693: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > Change variable specificOffsetFile,

[jira] [Updated] (FLINK-36036) CDC remove unused dependency jar from calcite-core

[ https://issues.apache.org/jira/browse/FLINK-36036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-36036: -- Fix Version/s: cdc-3.3.1 (was: cdc-3.3.0) > CDC remove unused dependency jar fr

[jira] [Updated] (FLINK-36036) CDC remove unused dependency jar from calcite-core

[ https://issues.apache.org/jira/browse/FLINK-36036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-36036: -- Issue Type: Technical Debt (was: Improvement) > CDC remove unused dependency jar from calcite-core >

[jira] [Updated] (FLINK-36163) Kafka cdc pipeline source supports protobuf format.

[ https://issues.apache.org/jira/browse/FLINK-36163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-36163: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > Kafka cdc pipeline source supports

[jira] [Updated] (FLINK-35664) Flink CDC pipeline transform supports mask function

[ https://issues.apache.org/jira/browse/FLINK-35664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35664: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.0) > Flink CDC pipeline transform suppor

[jira] [Updated] (FLINK-35586) Detected conflict when using Paimon as pipeline sink with parallelism > 1

[ https://issues.apache.org/jira/browse/FLINK-35586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35586: -- Fix Version/s: cdc-3.3.1 (was: cdc-3.3.0) > Detected conflict when using Paimon

[jira] [Updated] (FLINK-35586) Detected conflict when using Paimon as pipeline sink with parallelism > 1

[ https://issues.apache.org/jira/browse/FLINK-35586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35586: -- Fix Version/s: cdc-3.4.0 (was: cdc-3.3.1) > Detected conflict when using Paimon

[jira] [Updated] (FLINK-35567) CDC BinaryWriter cast NullableSerializerWrapper error

[ https://issues.apache.org/jira/browse/FLINK-35567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang updated FLINK-35567: -- Fix Version/s: cdc-3.3.1 (was: cdc-3.3.0) > CDC BinaryWriter cast NullableSeria

[jira] [Resolved] (FLINK-35344) Move same code from multiple subclasses to JdbcSourceChunkSplitter

[ https://issues.apache.org/jira/browse/FLINK-35344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang resolved FLINK-35344. --- Resolution: Fixed master(3.3-SNAOSHT) :47f5660055016460719bc8a9a72cee868e9aa6fe > Move same code fr

  1   2   3   4   >