[jira] [Resolved] (FLINK-35545) Miss 3.1.0 version in snapshot flink-cdc doc version list

[ https://issues.apache.org/jira/browse/FLINK-35545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35545. Resolution: Fixed > Miss 3.1.0 version in snapshot flink-cdc doc version list >

[jira] [Comment Edited] (FLINK-35545) Miss 3.1.0 version in snapshot flink-cdc doc version list

[ https://issues.apache.org/jira/browse/FLINK-35545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853114#comment-17853114 ] Leonard Xu edited comment on FLINK-35545 at 6/7/24 11:12 AM: -

[jira] [Commented] (FLINK-35545) Miss 3.1.0 version in snapshot flink-cdc doc version list

[ https://issues.apache.org/jira/browse/FLINK-35545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853114#comment-17853114 ] Leonard Xu commented on FLINK-35545: master:4efb1d78ca778abeae142facfa99440f22a88b25

[jira] [Updated] (FLINK-35545) Miss 3.1.0 version in snapshot flink-cdc doc version list

[ https://issues.apache.org/jira/browse/FLINK-35545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35545: --- Component/s: Documentation > Miss 3.1.0 version in snapshot flink-cdc doc version list >

[jira] [Updated] (FLINK-35545) Miss 3.1.0 version in snapshot flink-cdc doc version list

[ https://issues.apache.org/jira/browse/FLINK-35545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35545: --- Fix Version/s: cdc-3.2.0 cdc-3.1.1 > Miss 3.1.0 version in snapshot flink-cdc

[jira] [Resolved] (FLINK-35120) Add Doris Pipeline connector integration test cases

[ https://issues.apache.org/jira/browse/FLINK-35120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35120. Resolution: Implemented > Add Doris Pipeline connector integration test cases >

[jira] [Comment Edited] (FLINK-35120) Add Doris Pipeline connector integration test cases

[ https://issues.apache.org/jira/browse/FLINK-35120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17852670#comment-17852670 ] Leonard Xu edited comment on FLINK-35120 at 6/7/24 9:03 AM: master:

[jira] [Updated] (FLINK-35120) Add Doris Pipeline connector integration test cases

[ https://issues.apache.org/jira/browse/FLINK-35120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35120: --- Affects Version/s: cdc-3.1.0 > Add Doris Pipeline connector integration test cases >

[jira] [Updated] (FLINK-35120) Add Doris Pipeline connector integration test cases

[ https://issues.apache.org/jira/browse/FLINK-35120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35120: --- Fix Version/s: cdc-3.1.1 > Add Doris Pipeline connector integration test cases >

[jira] [Comment Edited] (FLINK-35415) CDC Fails to create sink with Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17852672#comment-17852672 ] Leonard Xu edited comment on FLINK-35415 at 6/7/24 9:01 AM: master:

[jira] [Resolved] (FLINK-35316) Add CDC e2e test case for on Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35316. Resolution: Fixed > Add CDC e2e test case for on Flink 1.19 >

[jira] [Resolved] (FLINK-35415) CDC Fails to create sink with Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35415. Resolution: Fixed > CDC Fails to create sink with Flink 1.19 >

[jira] [Comment Edited] (FLINK-35415) CDC Fails to create sink with Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17852672#comment-17852672 ] Leonard Xu edited comment on FLINK-35415 at 6/7/24 8:59 AM: master:

[jira] [Updated] (FLINK-35415) CDC Fails to create sink with Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35415: --- Fix Version/s: cdc-3.1.1 > CDC Fails to create sink with Flink 1.19 >

[jira] [Comment Edited] (FLINK-35316) Add CDC e2e test case for on Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17852671#comment-17852671 ] Leonard Xu edited comment on FLINK-35316 at 6/7/24 8:58 AM: master:

[jira] [Assigned] (FLINK-35316) Add CDC e2e test case for on Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35316: -- Assignee: yux > Add CDC e2e test case for on Flink 1.19 >

[jira] [Updated] (FLINK-35316) Add CDC e2e test case for on Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35316: --- Fix Version/s: cdc-3.2.0 cdc-3.1.1 > Add CDC e2e test case for on Flink 1.19 >

[jira] [Updated] (FLINK-35316) Add CDC e2e test case for on Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35316: --- Affects Version/s: cdc-3.1.0 > Add CDC e2e test case for on Flink 1.19 >

[jira] [Resolved] (FLINK-35092) Add integrated test for Doris / Starrocks sink pipeline connector

[ https://issues.apache.org/jira/browse/FLINK-35092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35092. Resolution: Implemented > Add integrated test for Doris / Starrocks sink pipeline connector >

[jira] [Comment Edited] (FLINK-35092) Add integrated test for Doris / Starrocks sink pipeline connector

[ https://issues.apache.org/jira/browse/FLINK-35092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17852669#comment-17852669 ] Leonard Xu edited comment on FLINK-35092 at 6/7/24 8:56 AM: master:

[jira] [Updated] (FLINK-35092) Add integrated test for Doris / Starrocks sink pipeline connector

[ https://issues.apache.org/jira/browse/FLINK-35092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35092: --- Affects Version/s: cdc-3.1.0 > Add integrated test for Doris / Starrocks sink pipeline connector >

[jira] [Updated] (FLINK-35092) Add integrated test for Doris / Starrocks sink pipeline connector

[ https://issues.apache.org/jira/browse/FLINK-35092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35092: --- Fix Version/s: cdc-3.1.1 > Add integrated test for Doris / Starrocks sink pipeline connector >

[jira] [Resolved] (FLINK-35464) Flink CDC 3.1 breaks operator state compatiblity

[ https://issues.apache.org/jira/browse/FLINK-35464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35464. Resolution: Fixed > Flink CDC 3.1 breaks operator state compatiblity >

[jira] [Updated] (FLINK-35464) Flink CDC 3.1 breaks operator state compatiblity

[ https://issues.apache.org/jira/browse/FLINK-35464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35464: --- Fix Version/s: cdc-3.2.0 > Flink CDC 3.1 breaks operator state compatiblity >

[jira] [Comment Edited] (FLINK-35464) Flink CDC 3.1 breaks operator state compatiblity

[ https://issues.apache.org/jira/browse/FLINK-35464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17852673#comment-17852673 ] Leonard Xu edited comment on FLINK-35464 at 6/7/24 8:52 AM: master:

[jira] [Assigned] (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 ] Leonard Xu reassigned FLINK-35544: -- Assignee: linqigeng > No description of Flink Operator in the Deployment of  Kubernetes

[jira] [Assigned] (FLINK-35242) Add fine-grained schema evolution strategy

[ https://issues.apache.org/jira/browse/FLINK-35242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35242: -- Assignee: yux > Add fine-grained schema evolution strategy >

[jira] [Updated] (FLINK-34908) [Feature][Pipeline] Mysql pipeline to doris and starrocks will lost precision for timestamp

[ https://issues.apache.org/jira/browse/FLINK-34908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-34908: --- Affects Version/s: cdc-3.1.0 > [Feature][Pipeline] Mysql pipeline to doris and starrocks will lost

[jira] [Updated] (FLINK-34908) [Feature][Pipeline] Mysql pipeline to doris and starrocks will lost precision for timestamp

[ https://issues.apache.org/jira/browse/FLINK-34908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-34908: --- Fix Version/s: cdc-3.1.1 > [Feature][Pipeline] Mysql pipeline to doris and starrocks will lost

[jira] [Commented] (FLINK-34908) [Feature][Pipeline] Mysql pipeline to doris and starrocks will lost precision for timestamp

[ https://issues.apache.org/jira/browse/FLINK-34908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17852752#comment-17852752 ] Leonard Xu commented on FLINK-34908: master: e2ccc836a056c16974e4956190bdce249705b7ee 3.1: todo >

[jira] [Updated] (FLINK-34908) [Feature][Pipeline] Mysql pipeline to doris and starrocks will lost precision for timestamp

[ https://issues.apache.org/jira/browse/FLINK-34908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-34908: --- Issue Type: Bug (was: Improvement) > [Feature][Pipeline] Mysql pipeline to doris and starrocks

[jira] [Commented] (FLINK-35464) Flink CDC 3.1 breaks operator state compatiblity

[ https://issues.apache.org/jira/browse/FLINK-35464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17852673#comment-17852673 ] Leonard Xu commented on FLINK-35464: master: 414720d1c5e9126ca557bf59389e9fb1b460c998 > Flink CDC

[jira] [Commented] (FLINK-35120) Add Doris Pipeline connector integration test cases

[ https://issues.apache.org/jira/browse/FLINK-35120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17852670#comment-17852670 ] Leonard Xu commented on FLINK-35120: master: 8eb7e53965e59c2f09c7d86461c095133e1d8998 > Add Doris

[jira] [Commented] (FLINK-35316) Add CDC e2e test case for on Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17852671#comment-17852671 ] Leonard Xu commented on FLINK-35316: master: d8a9c8c63ef5fb958a72c3a15e47ee29d72a481e > Add CDC e2e

[jira] [Commented] (FLINK-35415) CDC Fails to create sink with Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17852672#comment-17852672 ] Leonard Xu commented on FLINK-35415: master: 9a9603413c7c6d7094a30f8c8e676b65b0d3b9ba > CDC Fails

[jira] [Commented] (FLINK-35092) Add integrated test for Doris / Starrocks sink pipeline connector

[ https://issues.apache.org/jira/browse/FLINK-35092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17852669#comment-17852669 ] Leonard Xu commented on FLINK-35092: master: 1a360635c7ac936106e78d87867f96ed3f64e04b > Add

[jira] [Resolved] (FLINK-35325) Paimon connector miss the position of AddColumnEvent

[ https://issues.apache.org/jira/browse/FLINK-35325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35325. Resolution: Implemented via flink-cdc master: 02141660490855b033583e711152059c7652410f > Paimon

[jira] [Assigned] (FLINK-35325) Paimon connector miss the position of AddColumnEvent

[ https://issues.apache.org/jira/browse/FLINK-35325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35325: -- Assignee: tianzhu.wen > Paimon connector miss the position of AddColumnEvent >

[jira] [Resolved] (FLINK-35129) Postgres source commits the offset after every multiple checkpoint cycles.

[ https://issues.apache.org/jira/browse/FLINK-35129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35129. Resolution: Implemented Implemented via master: 5b28d1a579919b29acac6acded46d9bee5596bde >

[jira] [Resolved] (FLINK-35514) Add Flink CDC Channel to Apache Flink Slack Workspace

[ https://issues.apache.org/jira/browse/FLINK-35514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35514. Resolution: Implemented > Add Flink CDC Channel to Apache Flink Slack Workspace >

[jira] [Updated] (FLINK-35514) Add Flink CDC Channel to Apache Flink Slack Workspace

[ https://issues.apache.org/jira/browse/FLINK-35514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35514: --- Component/s: Build System > Add Flink CDC Channel to Apache Flink Slack Workspace >

[jira] [Updated] (FLINK-35514) Add Flink CDC Channel to Apache Flink Slack Workspace

[ https://issues.apache.org/jira/browse/FLINK-35514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35514: --- Affects Version/s: cdc-3.1.0 > Add Flink CDC Channel to Apache Flink Slack Workspace >

[jira] [Updated] (FLINK-35514) Add Flink CDC Channel to Apache Flink Slack Workspace

[ https://issues.apache.org/jira/browse/FLINK-35514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35514: --- Fix Version/s: cdc-3.2.0 > Add Flink CDC Channel to Apache Flink Slack Workspace >

[jira] [Commented] (FLINK-35514) Add Flink CDC Channel to Apache Flink Slack Workspace

[ https://issues.apache.org/jira/browse/FLINK-35514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17851879#comment-17851879 ] Leonard Xu commented on FLINK-35514: done > Add Flink CDC Channel to Apache Flink Slack Workspace >

[jira] [Commented] (FLINK-35496) The annotations of the new JDBC connector should be changed to non-Public/non-PublicEvolving

[ https://issues.apache.org/jira/browse/FLINK-35496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17851878#comment-17851878 ] Leonard Xu commented on FLINK-35496: > I commented it at >

[jira] [Commented] (FLINK-35514) Add Flink CDC Channel to Apache Flink Slack Workspace

[ https://issues.apache.org/jira/browse/FLINK-35514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17851868#comment-17851868 ] Leonard Xu commented on FLINK-35514: Let me have a try > Add Flink CDC Channel to Apache Flink

[jira] [Assigned] (FLINK-35514) Add Flink CDC Channel to Apache Flink Slack Workspace

[ https://issues.apache.org/jira/browse/FLINK-35514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35514: -- Assignee: Leonard Xu > Add Flink CDC Channel to Apache Flink Slack Workspace >

[jira] [Comment Edited] (FLINK-35496) The annotations of the new JDBC connector should be changed to non-Public/non-PublicEvolving

[ https://issues.apache.org/jira/browse/FLINK-35496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17851671#comment-17851671 ] Leonard Xu edited comment on FLINK-35496 at 6/3/24 2:43 PM: I just want to

[jira] [Commented] (FLINK-35496) The annotations of the new JDBC connector should be changed to non-Public/non-PublicEvolving

[ https://issues.apache.org/jira/browse/FLINK-35496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17851671#comment-17851671 ] Leonard Xu commented on FLINK-35496: I lust want to clarify two points here: （1）We can mark class

[jira] [Resolved] (FLINK-35294) Use source config to check if the filter should be applied in timestamp starting mode

[ https://issues.apache.org/jira/browse/FLINK-35294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35294. Resolution: Fixed > Use source config to check if the filter should be applied in timestamp >

[jira] [Comment Edited] (FLINK-35294) Use source config to check if the filter should be applied in timestamp starting mode

[ https://issues.apache.org/jira/browse/FLINK-35294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849615#comment-17849615 ] Leonard Xu edited comment on FLINK-35294 at 6/3/24 9:58 AM: Implemented via

[jira] [Updated] (FLINK-35294) Use source config to check if the filter should be applied in timestamp starting mode

[ https://issues.apache.org/jira/browse/FLINK-35294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35294: --- Fix Version/s: cdc-3.1.1 > Use source config to check if the filter should be applied in timestamp

[jira] [Reopened] (FLINK-35294) Use source config to check if the filter should be applied in timestamp starting mode

[ https://issues.apache.org/jira/browse/FLINK-35294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reopened FLINK-35294: > Use source config to check if the filter should be applied in timestamp > starting mode >

[jira] [Resolved] (FLINK-35430) ZoneId is not passed to DebeziumJsonSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-35430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35430. Resolution: Fixed Fixed via master: 0e8b2c7cc59db227dc0e15f219bd3d1b4c28ad42 3.1:

[jira] [Updated] (FLINK-35430) ZoneId is not passed to DebeziumJsonSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-35430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35430: --- Fix Version/s: cdc-3.2.0 > ZoneId is not passed to DebeziumJsonSerializationSchema >

[jira] [Assigned] (FLINK-35430) ZoneId is not passed to DebeziumJsonSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-35430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35430: -- Assignee: tianzhu.wen > ZoneId is not passed to DebeziumJsonSerializationSchema >

[jira] [Updated] (FLINK-35430) ZoneId is not passed to DebeziumJsonSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-35430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35430: --- Issue Type: Bug (was: Improvement) > ZoneId is not passed to DebeziumJsonSerializationSchema >

[jira] [Updated] (FLINK-35301) Fix deadlock when loading driver classes

[ https://issues.apache.org/jira/browse/FLINK-35301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35301: --- Fix Version/s: cdc-3.1.1 > Fix deadlock when loading driver classes >

[jira] [Comment Edited] (FLINK-35301) Fix deadlock when loading driver classes

[ https://issues.apache.org/jira/browse/FLINK-35301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849696#comment-17849696 ] Leonard Xu edited comment on FLINK-35301 at 6/3/24 8:31 AM: master:

[jira] [Comment Edited] (FLINK-35408) Add 30 min tolerance value when validating the time-zone setting

[ https://issues.apache.org/jira/browse/FLINK-35408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849699#comment-17849699 ] Leonard Xu edited comment on FLINK-35408 at 6/3/24 6:13 AM: Implemented in

[jira] [Comment Edited] (FLINK-35323) Only the schema of the first hit table is recorded when the source-table of the transformer hits multiple tables

[ https://issues.apache.org/jira/browse/FLINK-35323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17851498#comment-17851498 ] Leonard Xu edited comment on FLINK-35323 at 6/3/24 4:06 AM: master:

[jira] [Resolved] (FLINK-35323) Only the schema of the first hit table is recorded when the source-table of the transformer hits multiple tables

[ https://issues.apache.org/jira/browse/FLINK-35323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35323. Resolution: Fixed > Only the schema of the first hit table is recorded when the source-table of

[jira] [Commented] (FLINK-35323) Only the schema of the first hit table is recorded when the source-table of the transformer hits multiple tables

[ https://issues.apache.org/jira/browse/FLINK-35323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17851498#comment-17851498 ] Leonard Xu commented on FLINK-35323: master: 88afc5f18d051b52da86b5017dc896a4a66e6e10 > Only the

[jira] [Assigned] (FLINK-35494) Reorganize sources

[ https://issues.apache.org/jira/browse/FLINK-35494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35494: -- Assignee: João Boto > Reorganize sources > -- > > Key:

[jira] [Assigned] (FLINK-35370) Create a temp module to test backward compatibility

[ https://issues.apache.org/jira/browse/FLINK-35370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35370: -- Assignee: João Boto > Create a temp module to test backward compatibility >

[jira] [Assigned] (FLINK-35368) Reorganize table code

[ https://issues.apache.org/jira/browse/FLINK-35368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35368: -- Assignee: João Boto > Reorganize table code > - > > Key:

[jira] [Assigned] (FLINK-35367) Reorganize sinks

[ https://issues.apache.org/jira/browse/FLINK-35367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35367: -- Assignee: João Boto > Reorganize sinks > > > Key:

[jira] [Assigned] (FLINK-35364) Create core module and move code

[ https://issues.apache.org/jira/browse/FLINK-35364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35364: -- Assignee: João Boto > Create core module and move code > >

[jira] [Assigned] (FLINK-35366) Create all database modules

[ https://issues.apache.org/jira/browse/FLINK-35366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35366: -- Assignee: João Boto > Create all database modules > --- > >

[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=17851001#comment-17851001 ] Leonard Xu commented on FLINK-35363: Sure! > FLIP-449: Reorganization of flink-connector-jdbc >

[jira] [Assigned] (FLINK-35365) Reorganize catalog and dialect code

[ https://issues.apache.org/jira/browse/FLINK-35365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35365: -- Assignee: João Boto > Reorganize catalog and dialect code >

[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=17850901#comment-17850901 ] Leonard Xu commented on FLINK-35363: Hey [~eskabetxe]， assigned to you. > FLIP-449: Reorganization

[jira] [Assigned] (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 ] Leonard Xu reassigned FLINK-35363: -- Assignee: João Boto > FLIP-449: Reorganization of flink-connector-jdbc >

[jira] [Commented] (FLINK-35484) Flink document file had removed but website can access

[ https://issues.apache.org/jira/browse/FLINK-35484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17850900#comment-17850900 ] Leonard Xu commented on FLINK-35484: thanks [~gongzhongqiang] for the confirm, cool! > Flink

[jira] [Resolved] (FLINK-35484) Flink document file had removed but website can access

[ https://issues.apache.org/jira/browse/FLINK-35484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35484. Resolution: Fixed Fixed via master: b1841c0ff34b6e8d118139f6f87b7fdf06afacd3 > Flink document

[jira] [Resolved] (FLINK-35409) Request more splits if all splits are filtered from addSplits method

[ https://issues.apache.org/jira/browse/FLINK-35409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35409. Resolution: Implemented master via: 19c382c0f2f2736baeb1c652130cb30dd98ca90c > Request more

[jira] [Updated] (FLINK-35484) Flink document file had removed but website can access

[ https://issues.apache.org/jira/browse/FLINK-35484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35484: --- Fix Version/s: 1.20.0 > Flink document file had removed but website can access >

[jira] [Updated] (FLINK-35484) Flink document file had removed but website can access

[ https://issues.apache.org/jira/browse/FLINK-35484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35484: --- Affects Version/s: 1.19.0 > Flink document file had removed but website can access >

[jira] [Commented] (FLINK-35484) Flink document file had removed but website can access

[ https://issues.apache.org/jira/browse/FLINK-35484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17850558#comment-17850558 ] Leonard Xu commented on FLINK-35484: Thanks [~gongzhongqiang] for taking it, assigned to you >

[jira] [Assigned] (FLINK-35484) Flink document file had removed but website can access

[ https://issues.apache.org/jira/browse/FLINK-35484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35484: -- Assignee: Zhongqiang Gong > Flink document file had removed but website can access >

[jira] [Comment Edited] (FLINK-35447) Flink CDC Document document file had removed but website can access

[ https://issues.apache.org/jira/browse/FLINK-35447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849862#comment-17849862 ] Leonard Xu edited comment on FLINK-35447 at 5/28/24 2:58 AM: - master:

[jira] [Resolved] (FLINK-35447) Flink CDC Document document file had removed but website can access

[ https://issues.apache.org/jira/browse/FLINK-35447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35447. Resolution: Implemented > Flink CDC Document document file had removed but website can access >

[jira] [Commented] (FLINK-35447) Flink CDC Document document file had removed but website can access

[ https://issues.apache.org/jira/browse/FLINK-35447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849862#comment-17849862 ] Leonard Xu commented on FLINK-35447: master: d97124fb9f531193d8b232862af44e6bcca03277 > Flink CDC

[jira] [Updated] (FLINK-35447) Flink CDC Document document file had removed but website can access

[ https://issues.apache.org/jira/browse/FLINK-35447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35447: --- Fix Version/s: cdc-3.2.0 cdc-3.1.1 > Flink CDC Document document file had

[jira] [Updated] (FLINK-35447) Flink CDC Document document file had removed but website can access

[ https://issues.apache.org/jira/browse/FLINK-35447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35447: --- Affects Version/s: cdc-3.1.0 > Flink CDC Document document file had removed but website can access

[jira] [Assigned] (FLINK-35447) Flink CDC Document document file had removed but website can access

[ https://issues.apache.org/jira/browse/FLINK-35447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35447: -- Assignee: Zhongqiang Gong > Flink CDC Document document file had removed but website can

[jira] [Commented] (FLINK-35464) Flink CDC 3.1 breaks operator state compatiblity

[ https://issues.apache.org/jira/browse/FLINK-35464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849705#comment-17849705 ] Leonard Xu commented on FLINK-35464: Thanks [~xiqian_yu] for the investigation, and I improve the

[jira] [Assigned] (FLINK-35464) Flink CDC 3.1 breaks operator state compatiblity

[ https://issues.apache.org/jira/browse/FLINK-35464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35464: -- Assignee: yux > Flink CDC 3.1 breaks operator state compatiblity >

[jira] [Updated] (FLINK-35464) Flink CDC 3.1 breaks operator state compatiblity

[ https://issues.apache.org/jira/browse/FLINK-35464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35464: --- Priority: Blocker (was: Critical) > Flink CDC 3.1 breaks operator state compatiblity >

[jira] [Closed] (FLINK-35300) Improve MySqlStreamingChangeEventSource to skip null events in event deserializer

[ https://issues.apache.org/jira/browse/FLINK-35300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-35300. -- Resolution: Invalid > Improve MySqlStreamingChangeEventSource to skip null events in event >

[jira] [Updated] (FLINK-35323) Only the schema of the first hit table is recorded when the source-table of the transformer hits multiple tables

[ https://issues.apache.org/jira/browse/FLINK-35323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35323: --- Affects Version/s: cdc-3.1.0 > Only the schema of the first hit table is recorded when the

[jira] [Assigned] (FLINK-35323) Only the schema of the first hit table is recorded when the source-table of the transformer hits multiple tables

[ https://issues.apache.org/jira/browse/FLINK-35323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35323: -- Assignee: yux > Only the schema of the first hit table is recorded when the source-table of

[jira] [Updated] (FLINK-35323) Only the schema of the first hit table is recorded when the source-table of the transformer hits multiple tables

[ https://issues.apache.org/jira/browse/FLINK-35323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35323: --- Fix Version/s: cdc-3.1.1 cdc-3.2.0 > Only the schema of the first hit table is

[jira] [Assigned] (FLINK-35300) Improve MySqlStreamingChangeEventSource to skip null events in event deserializer

[ https://issues.apache.org/jira/browse/FLINK-35300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35300: -- Assignee: Xiao Huang > Improve MySqlStreamingChangeEventSource to skip null events in event

[jira] [Assigned] (FLINK-35409) Request more splits if all splits are filtered from addSplits method

[ https://issues.apache.org/jira/browse/FLINK-35409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35409: -- Assignee: Xiao Huang > Request more splits if all splits are filtered from addSplits method

[jira] [Resolved] (FLINK-35408) Add 30 min tolerance value when validating the time-zone setting

[ https://issues.apache.org/jira/browse/FLINK-35408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35408. Resolution: Implemented Implemented in master: b2cb30f2406502b5672f8ed8a3a8eaef1d6d6a07 > Add 30

[jira] [Commented] (FLINK-35408) Add 30 min tolerance value when validating the time-zone setting

[ https://issues.apache.org/jira/browse/FLINK-35408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849698#comment-17849698 ] Leonard Xu commented on FLINK-35408: I merged the PR after saw your comments [~davidradl]，and I

[jira] [Commented] (FLINK-35408) Add 30 min tolerance value when validating the time-zone setting

[ https://issues.apache.org/jira/browse/FLINK-35408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849697#comment-17849697 ] Leonard Xu commented on FLINK-35408: [~davidradl] I think a FLIP is not necessary as this minor

[jira] [Updated] (FLINK-35408) Add 30 min tolerance value when validating the time-zone setting

[ https://issues.apache.org/jira/browse/FLINK-35408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35408: --- Priority: Minor (was: Major) > Add 30 min tolerance value when validating the time-zone setting >

[jira] [Assigned] (FLINK-35408) Add 30 min tolerance value when validating the time-zone setting

[ https://issues.apache.org/jira/browse/FLINK-35408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35408: -- Assignee: Xiao Huang > Add 30 min tolerance value when validating the time-zone setting >

  1   2   3   4   5   6   7   8   9   10   >