[jira] [Created] (FLINK-35274) Occasional failure issue with Flink CDC Db2 UT

Xin Gong created FLINK-35274: Summary: Occasional failure issue with Flink CDC Db2 UT Key: FLINK-35274 URL: https://issues.apache.org/jira/browse/FLINK-35274 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-35274) Occasional failure issue with Flink CDC Db2 UT

[ https://issues.apache.org/jira/browse/FLINK-35274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Gong updated FLINK-35274: - Fix Version/s: 3.1.0 > Occasional failure issue with Flink CDC Db2 UT >

[jira] [Commented] (FLINK-35859) [flink-cdc] Fix: The assigner is not ready to offer finished split information, this should not be called

[ https://issues.apache.org/jira/browse/FLINK-35859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872271#comment-17872271 ] Xin Gong commented on FLINK-35859: -- [~loserwang1024] The PR will ignore newly table whe

[jira] [Created] (FLINK-34715) Fix mysql ut about closing BinlogSplitReader

Xin Gong created FLINK-34715: Summary: Fix mysql ut about closing BinlogSplitReader Key: FLINK-34715 URL: https://issues.apache.org/jira/browse/FLINK-34715 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-34715) Fix mysql ut about closing BinlogSplitReader

[ https://issues.apache.org/jira/browse/FLINK-34715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Gong updated FLINK-34715: - Description: BinlogSplitReaderTest#readBinlogSplitsFromSnapshotSplits should test binlog reader is clos

[jira] [Updated] (FLINK-34715) Fix mysql ut about closing BinlogSplitReader

[ https://issues.apache.org/jira/browse/FLINK-34715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Gong updated FLINK-34715: - External issue URL: https://github.com/apache/flink-cdc/pull/3161 > Fix mysql ut about closing BinlogSpl

[jira] [Commented] (FLINK-34715) Fix mysql ut about closing BinlogSplitReader

[ https://issues.apache.org/jira/browse/FLINK-34715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827885#comment-17827885 ] Xin Gong commented on FLINK-34715: -- [~Leonard] PTAL > Fix mysql ut about closing Binlo

[jira] [Created] (FLINK-34908) mysql pipeline to doris and starrocks will lost precision for timestamp

Xin Gong created FLINK-34908: Summary: mysql pipeline to doris and starrocks will lost precision for timestamp Key: FLINK-34908 URL: https://issues.apache.org/jira/browse/FLINK-34908 Project: Flink

[jira] [Updated] (FLINK-34908) 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 ] Xin Gong updated FLINK-34908: - Description: flink cdc pipeline will decide timestamp zone by config of pipeline. I found mysql2doris a

[jira] [Updated] (FLINK-34908) 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 ] Xin Gong updated FLINK-34908: - Description: flink cdc pipeline will decide timestamp zone by config of pipeline. I found mysql2doris a

[jira] [Updated] (FLINK-34908) 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 ] Xin Gong updated FLINK-34908: - Description: flink cdc pipeline will decide timestamp zone by config of pipeline. I found mysql2doris a

[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 ] Xin Gong updated FLINK-34908: - Summary: [Feature][Pipeline] Mysql pipeline to doris and starrocks will lost precision for timestamp (w

[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&focusedCommentId=17829495#comment-17829495 ] Xin Gong commented on FLINK-34908: -- I will submit a PR. cc [~Leonard]    > [Feature][P

[jira] [Created] (FLINK-34990) [feature][cdc-connector][oracle] Oracle cdc support newly add table

Xin Gong created FLINK-34990: Summary: [feature][cdc-connector][oracle] Oracle cdc support newly add table Key: FLINK-34990 URL: https://issues.apache.org/jira/browse/FLINK-34990 Project: Flink

[jira] [Commented] (FLINK-34990) [feature][cdc-connector][oracle] Oracle cdc support newly add table

[ https://issues.apache.org/jira/browse/FLINK-34990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833221#comment-17833221 ] Xin Gong commented on FLINK-34990: -- I will submit the PR. cc [~Leonard]  > [feature][c

[jira] [Updated] (FLINK-34990) [feature][cdc-connector][oracle] Oracle cdc support newly add table

[ https://issues.apache.org/jira/browse/FLINK-34990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Gong updated FLINK-34990: - External issue URL: https://github.com/apache/flink-cdc/pull/3203 > [feature][cdc-connector][oracle] Ora

[jira] [Updated] (FLINK-34990) [feature][cdc-connector][oracle] Oracle cdc support newly add table

[ https://issues.apache.org/jira/browse/FLINK-34990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Gong updated FLINK-34990: - External issue URL: (was: https://github.com/apache/flink-cdc/pull/3203) > [feature][cdc-connector][or

[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&focusedCommentId=17834589#comment-17834589 ] Xin Gong commented on FLINK-34908: -- Starrocks only support second precision. [https://

[jira] [Updated] (FLINK-35151) Flink mysql cdc will stuck when suspend binlog split and ChangeEventQueue is full

[ https://issues.apache.org/jira/browse/FLINK-35151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Gong updated FLINK-35151: - Environment: I use master branch reproduce it. (was: I use master branch reproduce it. Reason is that

[jira] [Created] (FLINK-35151) Flink mysql cdc will stuck when suspend binlog split and ChangeEventQueue is full

Xin Gong created FLINK-35151: Summary: Flink mysql cdc will stuck when suspend binlog split and ChangeEventQueue is full Key: FLINK-35151 URL: https://issues.apache.org/jira/browse/FLINK-35151 Project: F

[jira] [Updated] (FLINK-35151) Flink mysql cdc will stuck when suspend binlog split and ChangeEventQueue is full

[ https://issues.apache.org/jira/browse/FLINK-35151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Gong updated FLINK-35151: - Description: Flink mysql cdc will  stuck when suspend binlog split and ChangeEventQueue is full. Reaso

[jira] [Updated] (FLINK-35151) Flink mysql cdc will stuck when suspend binlog split and ChangeEventQueue is full

[ https://issues.apache.org/jira/browse/FLINK-35151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Gong updated FLINK-35151: - Description: Flink mysql cdc will  stuck when suspend binlog split and ChangeEventQueue is full. Reaso

[jira] [Commented] (FLINK-35151) Flink mysql cdc will stuck when suspend binlog split and ChangeEventQueue is full

[ https://issues.apache.org/jira/browse/FLINK-35151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838452#comment-17838452 ] Xin Gong commented on FLINK-35151: -- I get an idea to address this issue by set  curren

[jira] [Comment Edited] (FLINK-35151) Flink mysql cdc will stuck when suspend binlog split and ChangeEventQueue is full

[ https://issues.apache.org/jira/browse/FLINK-35151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838452#comment-17838452 ] Xin Gong edited comment on FLINK-35151 at 4/18/24 4:43 AM: --- I

[jira] [Comment Edited] (FLINK-35151) Flink mysql cdc will stuck when suspend binlog split and ChangeEventQueue is full

[ https://issues.apache.org/jira/browse/FLINK-35151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838452#comment-17838452 ] Xin Gong edited comment on FLINK-35151 at 4/18/24 4:44 AM: --- I

[jira] [Comment Edited] (FLINK-35151) Flink mysql cdc will stuck when suspend binlog split and ChangeEventQueue is full

[ https://issues.apache.org/jira/browse/FLINK-35151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838452#comment-17838452 ] Xin Gong edited comment on FLINK-35151 at 4/18/24 4:46 AM: --- I