[jira] [Commented] (FLINK-35303) Support logical deletion of data

[ https://issues.apache.org/jira/browse/FLINK-35303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844224#comment-17844224 ] LvYanquan commented on FLINK-35303: --- Currently, we can add a metadata column from row_

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

LvYanquan created FLINK-35325: - Summary: Paimon connector miss the position of AddColumnEvent Key: FLINK-35325 URL: https://issues.apache.org/jira/browse/FLINK-35325 Project: Flink Issue Type: Im

[jira] [Commented] (FLINK-34614) Add e2e test for Flink CDC pipeline job.

[ https://issues.apache.org/jira/browse/FLINK-34614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17847138#comment-17847138 ] LvYanquan commented on FLINK-34614: --- done in pull-request https://github.com/apache/fl

[jira] [Created] (FLINK-35391) Bump dependency of Paimon Pipeline connector to 0.8.0

LvYanquan created FLINK-35391: - Summary: Bump dependency of Paimon Pipeline connector to 0.8.0 Key: FLINK-35391 URL: https://issues.apache.org/jira/browse/FLINK-35391 Project: Flink Issue Type: I

[jira] [Updated] (FLINK-35391) Bump dependency of Paimon Pipeline connector to 0.8.0

[ https://issues.apache.org/jira/browse/FLINK-35391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-35391: -- Description: Apache Paimon has [released 0.8|https://paimon.apache.org/releases/release-0.8/] recently

[jira] [Commented] (FLINK-35391) Bump dependency of Paimon Pipeline connector to 0.8.0

[ https://issues.apache.org/jira/browse/FLINK-35391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17847748#comment-17847748 ] LvYanquan commented on FLINK-35391: --- Thanks for taking this, please go ahead, I am wil

[jira] [Commented] (FLINK-35421) Schema Operator blocking forever when Akka Rpc timeout

[ https://issues.apache.org/jira/browse/FLINK-35421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848788#comment-17848788 ] LvYanquan commented on FLINK-35421: --- Thanks for pointing out this issue. I am willing

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

LvYanquan created FLINK-35430: - Summary: ZoneId is not passed to DebeziumJsonSerializationSchema Key: FLINK-35430 URL: https://issues.apache.org/jira/browse/FLINK-35430 Project: Flink Issue Type:

[jira] [Created] (FLINK-35442) Kafka Pipeline Sink may distribute the same key to different partitions after modify parallelism

LvYanquan created FLINK-35442: - Summary: Kafka Pipeline Sink may distribute the same key to different partitions after modify parallelism Key: FLINK-35442 URL: https://issues.apache.org/jira/browse/FLINK-35442

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

LvYanquan created FLINK-35444: - Summary: Paimon Pipeline Connector support changing column names to lowercase for Hive metastore Key: FLINK-35444 URL: https://issues.apache.org/jira/browse/FLINK-35444 Pro

[jira] [Updated] (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 ] LvYanquan updated FLINK-35325: -- Fix Version/s: cdc-3.1.1 (was: cdc-3.2.0) > Paimon connector miss the position

[jira] [Updated] (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 ] LvYanquan updated FLINK-35325: -- Affects Version/s: cdc-3.1.1 (was: cdc-3.2.0) > Paimon connector miss the p

[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 ] LvYanquan updated FLINK-35430: -- Affects Version/s: cdc-3.1.1 (was: cdc-3.2.0) > ZoneId is not passed to Deb

[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 ] LvYanquan updated FLINK-35430: -- Fix Version/s: cdc-3.1.1 (was: cdc-3.2.0) > ZoneId is not passed to DebeziumJso

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

LvYanquan created FLINK-35586: - Summary: Detected conflict when using Paimon as pipeline sink with parallelism > 1 Key: FLINK-35586 URL: https://issues.apache.org/jira/browse/FLINK-35586 Project: Flink

[jira] [Commented] (FLINK-35237) Allow Sink to Choose HashFunction in PrePartitionOperator

[ https://issues.apache.org/jira/browse/FLINK-35237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854655#comment-17854655 ] LvYanquan commented on FLINK-35237: --- I've met the same demand in Paimon Sink, and I ag

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

LvYanquan created FLINK-35589: - Summary: Support MemorySize type in FlinkCDC ConfigOptions Key: FLINK-35589 URL: https://issues.apache.org/jira/browse/FLINK-35589 Project: Flink Issue Type: Impr

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

LvYanquan created FLINK-35627: - Summary: Avoid conflict when pipeline job that used Paimon as sink restart. Key: FLINK-35627 URL: https://issues.apache.org/jira/browse/FLINK-35627 Project: Flink

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

LvYanquan created FLINK-35684: - Summary: Add missing option for DataSource and DataSink Key: FLINK-35684 URL: https://issues.apache.org/jira/browse/FLINK-35684 Project: Flink Issue Type: Improvem

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

LvYanquan created FLINK-35718: - Summary: Cherrypick DBZ-5333 to fix frequently failover by EOFException. Key: FLINK-35718 URL: https://issues.apache.org/jira/browse/FLINK-35718 Project: Flink Is

[jira] [Created] (FLINK-35758) [Doc] add scan.startup.timestamp-millis options to MySQL connector docs.

LvYanquan created FLINK-35758: - Summary: [Doc] add scan.startup.timestamp-millis options to MySQL connector docs. Key: FLINK-35758 URL: https://issues.apache.org/jira/browse/FLINK-35758 Project: Flink

[jira] [Created] (FLINK-35791) Add database and table infos to Kafka json output.

LvYanquan created FLINK-35791: - Summary: Add database and table infos to Kafka json output. Key: FLINK-35791 URL: https://issues.apache.org/jira/browse/FLINK-35791 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-35802) Deadlock may happen after adding new tables

LvYanquan created FLINK-35802: - Summary: Deadlock may happen after adding new tables Key: FLINK-35802 URL: https://issues.apache.org/jira/browse/FLINK-35802 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-35802) Deadlock may happen after adding new tables

[ https://issues.apache.org/jira/browse/FLINK-35802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864522#comment-17864522 ] LvYanquan commented on FLINK-35802: --- Thanks, Please go ahead. > Deadlock may happen a

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

LvYanquan created FLINK-35834: - Summary: Update Doris Dependency to 1.6.2 to use group commit. Key: FLINK-35834 URL: https://issues.apache.org/jira/browse/FLINK-35834 Project: Flink Issue Type: B

[jira] [Created] (FLINK-35871) Add document for SNAPSHOT startup option mode

LvYanquan created FLINK-35871: - Summary: Add document for SNAPSHOT startup option mode Key: FLINK-35871 URL: https://issues.apache.org/jira/browse/FLINK-35871 Project: Flink Issue Type: Technica

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

LvYanquan created FLINK-35873: - Summary: Add HashFunctionProvider for Paimon DataSink. Key: FLINK-35873 URL: https://issues.apache.org/jira/browse/FLINK-35873 Project: Flink Issue Type: New Featu

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

LvYanquan created FLINK-35888: - Summary: Add e2e test for paimon DataSink Key: FLINK-35888 URL: https://issues.apache.org/jira/browse/FLINK-35888 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-35891) Support writing dynamic bucket table of Paimon

LvYanquan created FLINK-35891: - Summary: Support writing dynamic bucket table of Paimon Key: FLINK-35891 URL: https://issues.apache.org/jira/browse/FLINK-35891 Project: Flink Issue Type: Technic

[jira] [Created] (FLINK-35893) Add state compatibility for Serializer of TableChangeInfo

LvYanquan created FLINK-35893: - Summary: Add state compatibility for Serializer of TableChangeInfo Key: FLINK-35893 URL: https://issues.apache.org/jira/browse/FLINK-35893 Project: Flink Issue Ty

[jira] [Created] (FLINK-35938) Avoid commit the same datafile again in Paimon Sink.

LvYanquan created FLINK-35938: - Summary: Avoid commit the same datafile again in Paimon Sink. Key: FLINK-35938 URL: https://issues.apache.org/jira/browse/FLINK-35938 Project: Flink Issue Type: Te

[jira] [Created] (FLINK-36082) Fix NotSerializableException for KafkaDataSink

LvYanquan created FLINK-36082: - Summary: Fix NotSerializableException for KafkaDataSink Key: FLINK-36082 URL: https://issues.apache.org/jira/browse/FLINK-36082 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-36082) Fix NotSerializableException for KafkaDataSink

[ https://issues.apache.org/jira/browse/FLINK-36082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874601#comment-17874601 ] LvYanquan commented on FLINK-36082: --- I've found that it may related to lambda class in

[jira] [Created] (FLINK-36087) Fix

LvYanquan created FLINK-36087: - Summary: Fix Key: FLINK-36087 URL: https://issues.apache.org/jira/browse/FLINK-36087 Project: Flink Issue Type: Bug Reporter: LvYanquan -- This m

[jira] [Created] (FLINK-36088) Fix NopointException in PaimonDataSink.

LvYanquan created FLINK-36088: - Summary: Fix NopointException in PaimonDataSink. Key: FLINK-36088 URL: https://issues.apache.org/jira/browse/FLINK-36088 Project: Flink Issue Type: Bug C

[jira] [Closed] (FLINK-36087) Fix

[ https://issues.apache.org/jira/browse/FLINK-36087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan closed FLINK-36087. - Resolution: Fixed > Fix > --- > > Key: FLINK-36087 > URL: https://issues

[jira] [Updated] (FLINK-36088) Fix NopointException in PaimonDataSink.

[ https://issues.apache.org/jira/browse/FLINK-36088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-36088: -- Description: Fix NoPointException in BucketAssignOperator when job restarted. (was: Fix NopointExcept

[jira] [Created] (FLINK-36115) Allow to scan newly table DDL during incremental reading stage.

LvYanquan created FLINK-36115: - Summary: Allow to scan newly table DDL during incremental reading stage. Key: FLINK-36115 URL: https://issues.apache.org/jira/browse/FLINK-36115 Project: Flink Is

[jira] [Commented] (FLINK-36115) Allow to scan newly table DDL during incremental reading stage.

[ https://issues.apache.org/jira/browse/FLINK-36115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875353#comment-17875353 ] LvYanquan commented on FLINK-36115: --- I'm willing to support it. > Allow to scan newly

[jira] [Created] (FLINK-34671) Update the content of README.md in FlinkCDC project

LvYanquan created FLINK-34671: - Summary: Update the content of README.md in FlinkCDC project Key: FLINK-34671 URL: https://issues.apache.org/jira/browse/FLINK-34671 Project: Flink Issue Type: Imp

[jira] [Commented] (FLINK-34679) "Core Concept" Pages for Flink CDC Documentation

[ https://issues.apache.org/jira/browse/FLINK-34679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827332#comment-17827332 ] LvYanquan commented on FLINK-34679: --- I'm willing to take this. > "Core Concept" Pages

[jira] [Created] (FLINK-34691) failed to convert time type when using mysql to doris pipeline.

LvYanquan created FLINK-34691: - Summary: failed to convert time type when using mysql to doris pipeline. Key: FLINK-34691 URL: https://issues.apache.org/jira/browse/FLINK-34691 Project: Flink Is

[jira] [Updated] (FLINK-34691) failed to convert time type when using mysql to doris pipeline.

[ https://issues.apache.org/jira/browse/FLINK-34691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-34691: -- Fix Version/s: cdc-3.1.0 > failed to convert time type when using mysql to doris pipeline. > -

[jira] [Closed] (FLINK-34691) failed to convert time type when using mysql to doris pipeline.

[ https://issues.apache.org/jira/browse/FLINK-34691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan closed FLINK-34691. - Resolution: Invalid > failed to convert time type when using mysql to doris pipeline. >

[jira] [Commented] (FLINK-34681) "Deployment - Standalone" Page for Flink CDC Documentation

[ https://issues.apache.org/jira/browse/FLINK-34681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827421#comment-17827421 ] LvYanquan commented on FLINK-34681: --- I am willing to take this. > "Deployment - Stand

[jira] [Commented] (FLINK-34685) "Deployment - Kubernetes" Page for Flink CDC Documentation

[ https://issues.apache.org/jira/browse/FLINK-34685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828147#comment-17828147 ] LvYanquan commented on FLINK-34685: --- I am willing to take this. > "Deployment - Kuber

[jira] [Created] (FLINK-34729) "Core Concept" Pages for Flink CDC Chinese Documentation

LvYanquan created FLINK-34729: - Summary: "Core Concept" Pages for Flink CDC Chinese Documentation Key: FLINK-34729 URL: https://issues.apache.org/jira/browse/FLINK-34729 Project: Flink Issue Type

[jira] [Created] (FLINK-34730) "Deployment" Page for Flink CDC Chinese Documentation

LvYanquan created FLINK-34730: - Summary: "Deployment" Page for Flink CDC Chinese Documentation Key: FLINK-34730 URL: https://issues.apache.org/jira/browse/FLINK-34730 Project: Flink Issue Type: S

[jira] [Updated] (FLINK-34729) "Core Concept" Pages for Flink CDC Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-34729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-34729: -- Parent: (was: FLINK-34677) Issue Type: Improvement (was: Sub-task) > "Core Concept" Pages

[jira] [Updated] (FLINK-34729) "Core Concept" Pages for Flink CDC Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-34729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-34729: -- Parent: FLINK-34730 Issue Type: Sub-task (was: Improvement) > "Core Concept" Pages for Flink

[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 ] LvYanquan updated FLINK-34730: -- Description: As https://issues.apache.org/jira/browse/FLINK-34677 introduced new structure of Documen

[jira] [Updated] (FLINK-34729) "Core Concept" Pages for Flink CDC Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-34729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-34729: -- Description: Translate [Core Concept|https://github.com/apache/flink-cdc/tree/master/docs/content/doc

[jira] [Created] (FLINK-34734) Update the titles for Chinese Documents.

LvYanquan created FLINK-34734: - Summary: Update the titles for Chinese Documents. Key: FLINK-34734 URL: https://issues.apache.org/jira/browse/FLINK-34734 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-34734) Translate directory and page titles of Flink CDC docs to Chinese

[ https://issues.apache.org/jira/browse/FLINK-34734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828242#comment-17828242 ] LvYanquan commented on FLINK-34734: --- [~leonard]  Sure, I would like to do it. > Trans

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

LvYanquan created FLINK-34735: - Summary: "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Chinese Documentation Key: FLINK-34735 URL: https://issues.apache.org/jira/browse/FLINK-34735 Pr

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

LvYanquan created FLINK-34736: - Summary: "Deployment - Standalone" Page for Flink CDC Chinese Documentation Key: FLINK-34736 URL: https://issues.apache.org/jira/browse/FLINK-34736 Project: Flink

[jira] [Created] (FLINK-34737) "Deployment - Kubernetes" Page for Flink CDC Chinese Documentation

LvYanquan created FLINK-34737: - Summary: "Deployment - Kubernetes" Page for Flink CDC Chinese Documentation Key: FLINK-34737 URL: https://issues.apache.org/jira/browse/FLINK-34737 Project: Flink

[jira] [Created] (FLINK-34738) "Deployment - YARN" Page for Flink CDC Chinese Documentation

LvYanquan created FLINK-34738: - Summary: "Deployment - YARN" Page for Flink CDC Chinese Documentation Key: FLINK-34738 URL: https://issues.apache.org/jira/browse/FLINK-34738 Project: Flink Issue

[jira] [Created] (FLINK-34739) "Connectors" Page for Flink CDC Chinese Documentation

LvYanquan created FLINK-34739: - Summary: "Connectors" Page for Flink CDC Chinese Documentation Key: FLINK-34739 URL: https://issues.apache.org/jira/browse/FLINK-34739 Project: Flink Issue Type: S

[jira] [Created] (FLINK-34740) "legacy-flink-cdc-sources" Pages for Flink CDC Chinese Documentation

LvYanquan created FLINK-34740: - Summary: "legacy-flink-cdc-sources" Pages for Flink CDC Chinese Documentation Key: FLINK-34740 URL: https://issues.apache.org/jira/browse/FLINK-34740 Project: Flink

[jira] [Created] (FLINK-34741) "get-started" Page for Flink CDC Chinese Documentation

LvYanquan created FLINK-34741: - Summary: "get-started" Page for Flink CDC Chinese Documentation Key: FLINK-34741 URL: https://issues.apache.org/jira/browse/FLINK-34741 Project: Flink Issue Type:

[jira] [Created] (FLINK-34742) Translate "FAQ" Page for Flink CDC Chinese Documentation

LvYanquan created FLINK-34742: - Summary: Translate "FAQ" Page for Flink CDC Chinese Documentation Key: FLINK-34742 URL: https://issues.apache.org/jira/browse/FLINK-34742 Project: Flink Issue Type

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17828567#comment-17828567 ] LvYanquan commented on FLINK-34735: --- I am willing to do this. > "Developer Guide - Un

[jira] [Commented] (FLINK-34729) "Core Concept" Pages for Flink CDC Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-34729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828566#comment-17828566 ] LvYanquan commented on FLINK-34729: --- I am willing to do this. > "Core Concept" Pages

[jira] [Updated] (FLINK-34740) "legacy-flink-cdc-sources" Pages for Flink CDC Chinese Documentation existed in 2.x version.

[ https://issues.apache.org/jira/browse/FLINK-34740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-34740: -- Summary: "legacy-flink-cdc-sources" Pages for Flink CDC Chinese Documentation existed in 2.x version.

[jira] [Updated] (FLINK-34740) "legacy-flink-cdc-sources" Pages for Flink CDC Chinese Documentation existed in 2.x version.

[ https://issues.apache.org/jira/browse/FLINK-34740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-34740: -- Description: Translate legacy-flink-cdc-sources pages of [https://github.com/apache/flink-cdc/tree/ma

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

LvYanquan created FLINK-34747: - Summary: "legacy-flink-cdc-sources" Page of DB2 for Flink CDC Chinese Documentation. Key: FLINK-34747 URL: https://issues.apache.org/jira/browse/FLINK-34747 Project: Flink

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

LvYanquan created FLINK-34748: - Summary: "legacy-flink-cdc-sources" Page of Oracle for Flink CDC Chinese Documentation. Key: FLINK-34748 URL: https://issues.apache.org/jira/browse/FLINK-34748 Project: Fli

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

LvYanquan created FLINK-34749: - Summary: "legacy-flink-cdc-sources" Page of SQLServer for Flink CDC Chinese Documentation. Key: FLINK-34749 URL: https://issues.apache.org/jira/browse/FLINK-34749 Project:

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

LvYanquan created FLINK-34750: - Summary: "legacy-flink-cdc-sources" Page of DB2 for Flink CDC Chinese Documentation. Key: FLINK-34750 URL: https://issues.apache.org/jira/browse/FLINK-34750 Project: Flink

[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 ] LvYanquan updated FLINK-34750: -- Summary: "legacy-flink-cdc-sources" Page of Postgresql for Flink CDC Chinese Documentation. (was: "le

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

LvYanquan created FLINK-34752: - Summary: "legacy-flink-cdc-sources" Page of TIDB for Flink CDC Chinese Documentation. Key: FLINK-34752 URL: https://issues.apache.org/jira/browse/FLINK-34752 Project: Flink

[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 ] LvYanquan updated FLINK-34752: -- Description: Translate legacy-flink-cdc-sources pages of https://github.com/apache/flink-cdc/blob/mast

[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 ] LvYanquan updated FLINK-34750: -- Description: Translate legacy-flink-cdc-sources pages of https://github.com/apache/flink-cdc/blob/mast

[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 ] LvYanquan updated FLINK-34750: -- Description: Translate legacy-flink-cdc-sources pages of https://github.com/apache/flink-cdc/blob/mast

[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 ] LvYanquan updated FLINK-34748: -- Description: Translate legacy-flink-cdc-sources pages of https://github.com/apache/flink-cdc/blob/mast

[jira] [Commented] (FLINK-34740) "legacy-flink-cdc-sources" Pages for Flink CDC Chinese Documentation existed in 2.x version.

[ https://issues.apache.org/jira/browse/FLINK-34740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828660#comment-17828660 ] LvYanquan commented on FLINK-34740: --- Sorry for [~loserwang1024], I didn't notice that

[jira] [Created] (FLINK-34770) Unify download links of legacy connector to fat jar

LvYanquan created FLINK-34770: - Summary: Unify download links of legacy connector to fat jar Key: FLINK-34770 URL: https://issues.apache.org/jira/browse/FLINK-34770 Project: Flink Issue Type: Sub

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17837975#comment-17837975 ] LvYanquan commented on FLINK-34752: --- [~siriusfan] Thanks for taking this, I don't have

[jira] [Created] (FLINK-35213) A potential inconsistent table structure issue

LvYanquan created FLINK-35213: - Summary: A potential inconsistent table structure issue Key: FLINK-35213 URL: https://issues.apache.org/jira/browse/FLINK-35213 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-35235) Fix missing dependencies in the uber jar

LvYanquan created FLINK-35235: - Summary: Fix missing dependencies in the uber jar Key: FLINK-35235 URL: https://issues.apache.org/jira/browse/FLINK-35235 Project: Flink Issue Type: Improvement

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

LvYanquan created FLINK-34595: - Summary: Fix ClassNotFoundException: com.ververica.cdc.common.utils.StringUtils Key: FLINK-34595 URL: https://issues.apache.org/jira/browse/FLINK-34595 Project: Flink

[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 ] LvYanquan updated FLINK-34595: -- Description: In [this pr|[https://github.com/apache/flink-cdc/pull/2986/files#diff-cec13810c47e9465e4

[jira] [Created] (FLINK-34613) allow specifing a savepoint file to restart using cli script.

LvYanquan created FLINK-34613: - Summary: allow specifing a savepoint file to restart using cli script. Key: FLINK-34613 URL: https://issues.apache.org/jira/browse/FLINK-34613 Project: Flink Issu

[jira] [Created] (FLINK-34614) Add e2e test for Flink CDC pipeline job.

LvYanquan created FLINK-34614: - Summary: Add e2e test for Flink CDC pipeline job. Key: FLINK-34614 URL: https://issues.apache.org/jira/browse/FLINK-34614 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-34585) [JUnit5 Migration] Module: Flink CDC

[ https://issues.apache.org/jira/browse/FLINK-34585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825121#comment-17825121 ] LvYanquan commented on FLINK-34585: --- I am willing to take this. > [JUnit5 Migration]

[jira] [Created] (FLINK-34638) Support default value of table column.

LvYanquan created FLINK-34638: - Summary: Support default value of table column. Key: FLINK-34638 URL: https://issues.apache.org/jira/browse/FLINK-34638 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-34648) Avoid RPC time when apply SchemaChangeEvent to external system

LvYanquan created FLINK-34648: - Summary: Avoid RPC time when apply SchemaChangeEvent to external system Key: FLINK-34648 URL: https://issues.apache.org/jira/browse/FLINK-34648 Project: Flink Iss

[jira] [Commented] (FLINK-34648) Avoid RPC time when apply SchemaChangeEvent to external system

[ https://issues.apache.org/jira/browse/FLINK-34648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825538#comment-17825538 ] LvYanquan commented on FLINK-34648: --- Enumerator will not restart but add splits back.

[jira] [Updated] (FLINK-34648) Avoid RPC time when apply SchemaChangeEvent to external system

[ https://issues.apache.org/jira/browse/FLINK-34648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-34648: -- Attachment: 截屏2024-03-12 14.55.09.png > Avoid RPC time when apply SchemaChangeEvent to external system

[jira] [Comment Edited] (FLINK-34648) Avoid RPC time when apply SchemaChangeEvent to external system

[ https://issues.apache.org/jira/browse/FLINK-34648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825538#comment-17825538 ] LvYanquan edited comment on FLINK-34648 at 3/12/24 7:07 AM:

[jira] [Commented] (FLINK-36141) [mysql]Set the scanNewlyAddedTableEnabled is true, but does not support automatic capture new added table

[ https://issues.apache.org/jira/browse/FLINK-36141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876200#comment-17876200 ] LvYanquan commented on FLINK-36141: --- Thanks for reporting this, fixed in https://gith

[jira] [Created] (FLINK-36148) Support parsing DDL to new CreateTableEvent in binlog reading phase.

LvYanquan created FLINK-36148: - Summary: Support parsing DDL to new CreateTableEvent in binlog reading phase. Key: FLINK-36148 URL: https://issues.apache.org/jira/browse/FLINK-36148 Project: Flink

[jira] [Commented] (FLINK-36148) Support parsing DDL to new CreateTableEvent in binlog reading phase.

[ https://issues.apache.org/jira/browse/FLINK-36148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876398#comment-17876398 ] LvYanquan commented on FLINK-36148: --- I'm willing to fix this. > Support parsing DDL t

[jira] [Created] (FLINK-36178) Parse CREATE TABLE LIKE to CreateTableEvent

LvYanquan created FLINK-36178: - Summary: Parse CREATE TABLE LIKE to CreateTableEvent Key: FLINK-36178 URL: https://issues.apache.org/jira/browse/FLINK-36178 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-36178) Parse CREATE TABLE LIKE to CreateTableEvent

[ https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-36178: -- Summary: Parse CREATE TABLE LIKE to CreateTableEvent (was: Parse CREATE TABLE LIKE to CreateTableEve

[jira] [Updated] (FLINK-36178) Parse CREATE TABLE LIKE to CreateTableEvent

[ https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-36178: -- Fix Version/s: cdc-3.2.0 > Parse CREATE TABLE LIKE to CreateTableEvent >

[jira] [Updated] (FLINK-36178) Parse CREATE TABLE LIKE to CreateTableEvent

[ https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-36178: -- Affects Version/s: cdc-3.2.0 > Parse CREATE TABLE LIKE to CreateTableEvent >

[jira] [Updated] (FLINK-36178) Parse CREATE TABLE LIKE to CreateTableEvent

[ https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-36178: -- Labels: cdc (was: ) > Parse CREATE TABLE LIKE to CreateTableEvent >

[jira] [Updated] (FLINK-36178) Parse CREATE TABLE LIKE to CreateTableEvent

[ https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-36178: -- Description: Currently, {{CREATE TABLE `user_log_copy_2` LIKE `user_log` SQL is not correctly parsed,

  1   2   >