[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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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-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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [Created] (FLINK-36211) Shade kafka related package in Kafka Pipeline connector.

LvYanquan created FLINK-36211: - Summary: Shade kafka related package in Kafka Pipeline connector. Key: FLINK-36211 URL: https://issues.apache.org/jira/browse/FLINK-36211 Project: Flink Issue Type

[jira] [Created] (FLINK-36263) Include only changed columns in old for canal format in Kakfa Sink

LvYanquan created FLINK-36263: - Summary: Include only changed columns in old for canal format in Kakfa Sink Key: FLINK-36263 URL: https://issues.apache.org/jira/browse/FLINK-36263 Project: Flink

[jira] [Created] (FLINK-36516) Migrate deprecated SinkV2 API to new API introduced in FLIP-372

LvYanquan created FLINK-36516: - Summary: Migrate deprecated SinkV2 API to new API introduced in FLIP-372 Key: FLINK-36516 URL: https://issues.apache.org/jira/browse/FLINK-36516 Project: Flink

[jira] [Created] (FLINK-36541) Occasional met commit conflict problem in PaimonSink.

LvYanquan created FLINK-36541: - Summary: Occasional met commit conflict problem in PaimonSink. Key: FLINK-36541 URL: https://issues.apache.org/jira/browse/FLINK-36541 Project: Flink Issue Type: I

[jira] [Created] (FLINK-36452) Avoid EOFException when reading binlog after a large table has just completed snapshot reading

LvYanquan created FLINK-36452: - Summary: Avoid EOFException when reading binlog after a large table has just completed snapshot reading Key: FLINK-36452 URL: https://issues.apache.org/jira/browse/FLINK-36452

[jira] [Created] (FLINK-36509) Fix 'Unsupported bucket mode: GLOBAL_DYNAMIC' error in Paimon Pipeline Sink.

LvYanquan created FLINK-36509: - Summary: Fix 'Unsupported bucket mode: GLOBAL_DYNAMIC' error in Paimon Pipeline Sink. Key: FLINK-36509 URL: https://issues.apache.org/jira/browse/FLINK-36509 Project: Flink

[jira] [Created] (FLINK-36560) Fix the issue of timestamp_ltz increasing by 8 hours in Paimon

LvYanquan created FLINK-36560: - Summary: Fix the issue of timestamp_ltz increasing by 8 hours in Paimon Key: FLINK-36560 URL: https://issues.apache.org/jira/browse/FLINK-36560 Project: Flink Iss

[jira] [Created] (FLINK-36563) Running CI in random timezone to expose more time related bugs

LvYanquan created FLINK-36563: - Summary: Running CI in random timezone to expose more time related bugs Key: FLINK-36563 URL: https://issues.apache.org/jira/browse/FLINK-36563 Project: Flink I

[jira] [Created] (FLINK-36566) Code optimization: always identify DataChangeEvent before SchemaChangeEvent in Operator

LvYanquan created FLINK-36566: - Summary: Code optimization: always identify DataChangeEvent before SchemaChangeEvent in Operator Key: FLINK-36566 URL: https://issues.apache.org/jira/browse/FLINK-36566 Pro

[jira] [Created] (FLINK-36562) Running CI in random timezone to expose more time related bugs

LvYanquan created FLINK-36562: - Summary: Running CI in random timezone to expose more time related bugs Key: FLINK-36562 URL: https://issues.apache.org/jira/browse/FLINK-36562 Project: Flink I

[jira] [Created] (FLINK-36564) Running CI in random timezone to expose more time related bugs

LvYanquan created FLINK-36564: - Summary: Running CI in random timezone to expose more time related bugs Key: FLINK-36564 URL: https://issues.apache.org/jira/browse/FLINK-36564 Project: Flink Is

[jira] [Created] (FLINK-36459) Add document to guide user to configure debezium properties

LvYanquan created FLINK-36459: - Summary: Add document to guide user to configure debezium properties Key: FLINK-36459 URL: https://issues.apache.org/jira/browse/FLINK-36459 Project: Flink Issue

[jira] [Created] (FLINK-36581) Allow passing Flink configuration by yaml job file or command line parameters

LvYanquan created FLINK-36581: - Summary: Allow passing Flink configuration by yaml job file or command line parameters Key: FLINK-36581 URL: https://issues.apache.org/jira/browse/FLINK-36581 Project: Flin

[jira] [Created] (FLINK-36660) Release flink-connector-elasticsearch vx.x.x for Flink 2.0

LvYanquan created FLINK-36660: - Summary: Release flink-connector-elasticsearch vx.x.x for Flink 2.0 Key: FLINK-36660 URL: https://issues.apache.org/jira/browse/FLINK-36660 Project: Flink Issue Ty

[jira] [Created] (FLINK-36658) Support and Release Connectors for Flink 2.0

LvYanquan created FLINK-36658: - Summary: Support and Release Connectors for Flink 2.0 Key: FLINK-36658 URL: https://issues.apache.org/jira/browse/FLINK-36658 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-36659) Release flink-connector-jdbc vx.x.x for Flink 2.0

LvYanquan created FLINK-36659: - Summary: Release flink-connector-jdbc vx.x.x for Flink 2.0 Key: FLINK-36659 URL: https://issues.apache.org/jira/browse/FLINK-36659 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-36611) Add schema info to output of Kafka sink

LvYanquan created FLINK-36611: - Summary: Add schema info to output of Kafka sink Key: FLINK-36611 URL: https://issues.apache.org/jira/browse/FLINK-36611 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-36641) Support and Release Connectors for Flink 1.20

LvYanquan created FLINK-36641: - Summary: Support and Release Connectors for Flink 1.20 Key: FLINK-36641 URL: https://issues.apache.org/jira/browse/FLINK-36641 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-36648) bump flink version to 2.0-preview1 for Kafka connector

LvYanquan created FLINK-36648: - Summary: bump flink version to 2.0-preview1 for Kafka connector Key: FLINK-36648 URL: https://issues.apache.org/jira/browse/FLINK-36648 Project: Flink Issue Type:

[jira] [Created] (FLINK-36413) Reenable the test case that related to Source/Sink APi deprecated.

LvYanquan created FLINK-36413: - Summary: Reenable the test case that related to Source/Sink APi deprecated. Key: FLINK-36413 URL: https://issues.apache.org/jira/browse/FLINK-36413 Project: Flink