[jira] [Created] (FLINK-35655) Support more pipeline sources

linqigeng created FLINK-35655: - Summary: Support more pipeline sources Key: FLINK-35655 URL: https://issues.apache.org/jira/browse/FLINK-35655 Project: Flink Issue Type: New Feature Com

[jira] [Created] (FLINK-36282) Incorrect data type mysql pipeline connector

linqigeng created FLINK-36282: - Summary: Incorrect data type mysql pipeline connector Key: FLINK-36282 URL: https://issues.apache.org/jira/browse/FLINK-36282 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-36282) Incorrect data type in mysql pipeline connector

[ https://issues.apache.org/jira/browse/FLINK-36282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linqigeng updated FLINK-36282: -- Summary: Incorrect data type in mysql pipeline connector (was: Incorrect data type mysql pipeline con

[jira] [Created] (FLINK-36285) Modify column type failed when downstream's column with defalut value

linqigeng created FLINK-36285: - Summary: Modify column type failed when downstream's column with defalut value Key: FLINK-36285 URL: https://issues.apache.org/jira/browse/FLINK-36285 Project: Flink

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

linqigeng created FLINK-35544: - Summary: No description of Flink Operator in the Deployment of  Kubernetes document Key: FLINK-35544 URL: https://issues.apache.org/jira/browse/FLINK-35544 Project: Flink

[jira] [Created] (FLINK-35547) Sources support HybridSource implements

linqigeng created FLINK-35547: - Summary: Sources support HybridSource implements Key: FLINK-35547 URL: https://issues.apache.org/jira/browse/FLINK-35547 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-36619) Downstream lost the CreateTableEvent when tables were removed and then re-added

[ https://issues.apache.org/jira/browse/FLINK-36619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linqigeng updated FLINK-36619: -- Description: If some tables are removed from the `tables` parameter and then re-added, the `CreateTab

[jira] [Updated] (FLINK-36619) Downstream lost the CreateTableEvent when tables were removed and then re-added

[ https://issues.apache.org/jira/browse/FLINK-36619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linqigeng updated FLINK-36619: -- Description: If some tables are removed from the `tables` parameter and then re-added, the `CreateTab

[jira] [Updated] (FLINK-36619) Downstream lost the CreateTableEvent when tables were removed and then re-added

[ https://issues.apache.org/jira/browse/FLINK-36619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linqigeng updated FLINK-36619: -- Description: If some tables are removed from the `tables` parameter and then re-added, the `CreateTab

[jira] [Updated] (FLINK-36619) Downstream lost the CreateTableEvent when tables were removed and then re-added

[ https://issues.apache.org/jira/browse/FLINK-36619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linqigeng updated FLINK-36619: -- Description: If some tables are removed from the `tables` parameter and then re-added, the `CreateTab

[jira] [Updated] (FLINK-36619) Downstream lost the CreateTableEvent when tables were removed and then re-added

[ https://issues.apache.org/jira/browse/FLINK-36619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linqigeng updated FLINK-36619: -- Attachment: image-2024-10-29-12-04-26-718.png > Downstream lost the CreateTableEvent when tables were

[jira] [Updated] (FLINK-36619) Downstream lost the CreateTableEvent when tables were removed and then re-added

[ https://issues.apache.org/jira/browse/FLINK-36619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linqigeng updated FLINK-36619: -- Description: If some tables are removed from the `tables` parameter and then re-added, the `CreateTab

[jira] [Created] (FLINK-36619) Downstream lost the CreateTableEvent when tables were removed and then re-added

linqigeng created FLINK-36619: - Summary: Downstream lost the CreateTableEvent when tables were removed and then re-added Key: FLINK-36619 URL: https://issues.apache.org/jira/browse/FLINK-36619 Project: Fl

[jira] [Updated] (FLINK-36619) Downstream lost the CreateTableEvent when tables were removed and then re-added

[ https://issues.apache.org/jira/browse/FLINK-36619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linqigeng updated FLINK-36619: -- Description: If some tables are removed from the `tables` parameter and then re-added, the `CreateTab

[jira] [Updated] (FLINK-36619) Downstream lost the CreateTableEvent when tables were removed and then re-added

[ https://issues.apache.org/jira/browse/FLINK-36619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linqigeng updated FLINK-36619: -- Description: If some tables are removed from the `tables` parameter and then re-added, the `CreateTab

[jira] [Resolved] (FLINK-36375) Missing default value in AddColumnEvent/RenameColumnEvent

[ https://issues.apache.org/jira/browse/FLINK-36375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linqigeng resolved FLINK-36375. --- Resolution: Fixed > Missing default value in AddColumnEvent/RenameColumnEvent >

[jira] [Created] (FLINK-36375) Missing default value in AddColumnEvent

linqigeng created FLINK-36375: - Summary: Missing default value in AddColumnEvent Key: FLINK-36375 URL: https://issues.apache.org/jira/browse/FLINK-36375 Project: Flink Issue Type: Bug C

[jira] [Updated] (FLINK-36375) Missing default value in AddColumnEvent/RenameColumnEvent

[ https://issues.apache.org/jira/browse/FLINK-36375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linqigeng updated FLINK-36375: -- Description: SchemaOperator receives an AddColumnEvent or RenameColumnEvent, the default value will b

[jira] [Created] (FLINK-36326) Newly added table failed in mysql pipeline connector

linqigeng created FLINK-36326: - Summary: Newly added table failed in mysql pipeline connector Key: FLINK-36326 URL: https://issues.apache.org/jira/browse/FLINK-36326 Project: Flink Issue Type: Bu

[jira] [Updated] (FLINK-36619) Downstream lost the CreateTableEvent when tables were removed and then re-added

[ https://issues.apache.org/jira/browse/FLINK-36619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linqigeng updated FLINK-36619: -- Description: #CDC 3.2: If some tables are removed from the `tables` parameter and then re-added, the

[jira] [Updated] (FLINK-36619) Downstream lost the CreateTableEvent when tables were removed and then re-added

[ https://issues.apache.org/jira/browse/FLINK-36619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linqigeng updated FLINK-36619: -- Affects Version/s: cdc-3.3.0 Description: ## CDC 3.2: If some tables are removed from the `

[jira] [Updated] (FLINK-36619) Downstream lost the CreateTableEvent when tables were removed and then re-added

[ https://issues.apache.org/jira/browse/FLINK-36619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linqigeng updated FLINK-36619: -- Description: If some tables are removed from the `tables` parameter and then re-added, the `CreateTab

[jira] [Commented] (FLINK-35152) Flink CDC Doris Sink Auto create table event should support setting auto partition fields for each table

[ https://issues.apache.org/jira/browse/FLINK-35152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913173#comment-17913173 ] linqigeng commented on FLINK-35152: --- I'd like to implement this. > Flink CDC Doris S

[jira] [Created] (FLINK-37537) Duplicate key when job failover in SchemaOperator

linqigeng created FLINK-37537: - Summary: Duplicate key when job failover in SchemaOperator Key: FLINK-37537 URL: https://issues.apache.org/jira/browse/FLINK-37537 Project: Flink Issue Type: Bug