[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

[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-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

[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=17848788#comment-17848788 ] LvYanquan commented on FLINK-35421: --- Thanks for pointing out this issue. I am willing to fix it. >

[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=17847748#comment-17847748 ] LvYanquan commented on FLINK-35391: --- Thanks for taking this, please go ahead, I am willing to help

[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/]

[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:

[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=17847138#comment-17847138 ] LvYanquan commented on FLINK-34614: --- done in pull-request

[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:

[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=17844224#comment-17844224 ] LvYanquan commented on FLINK-35303: --- Currently, we can add a metadata column from row_kind

[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-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:

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

[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:

[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=17828660#comment-17828660 ] LvYanquan commented on FLINK-34740: --- Sorry for [~loserwang1024], I didn't notice that you had comment

[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

[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

[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

[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

[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:

[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:

[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] [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-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:

[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] [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

[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] [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=17828566#comment-17828566 ] LvYanquan commented on FLINK-34729: --- I am willing to do this. > "Core Concept" Pages for Flink CDC

[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=17828567#comment-17828567 ] LvYanquan commented on FLINK-34735: --- I am willing to do this. > "Developer Guide - Understanding

[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

[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-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-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:

[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

[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-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-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

[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=17828242#comment-17828242 ] LvYanquan commented on FLINK-34734: --- [~leonard]  Sure, I would like to do it. > Translate directory

[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] [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

[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

[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-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"

[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:

[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

[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=17828147#comment-17828147 ] LvYanquan commented on FLINK-34685: --- I am willing to take this. > "Deployment - Kubernetes" Page for

[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=17827421#comment-17827421 ] LvYanquan commented on FLINK-34681: --- I am willing to take this. > "Deployment - Standalone" Page for

[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] [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] [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

[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=17827332#comment-17827332 ] LvYanquan commented on FLINK-34679: --- I'm willing to take this. > "Core Concept" Pages for Flink CDC

[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:

[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=17825538#comment-17825538 ] LvYanquan edited comment on FLINK-34648 at 3/12/24 7:07 AM: Enumerator will

[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

[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=17825538#comment-17825538 ] LvYanquan commented on FLINK-34648: --- Enumerator will not restart but add splits back. > Avoid RPC

[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

[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] [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=17825121#comment-17825121 ] LvYanquan commented on FLINK-34585: --- I am willing to take this. > [JUnit5 Migration] Module: Flink

[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] [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

[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

[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