[jira] [Created] (FLINK-37252) Align Chinese document of Postgres CDC Connector with English document

Yanquan Lv created FLINK-37252: -- Summary: Align Chinese document of Postgres CDC Connector with English document Key: FLINK-37252 URL: https://issues.apache.org/jira/browse/FLINK-37252 Project: Flink

[jira] [Created] (FLINK-37251) Add download link for pipeline connector.

Yanquan Lv created FLINK-37251: -- Summary: Add download link for pipeline connector. Key: FLINK-37251 URL: https://issues.apache.org/jira/browse/FLINK-37251 Project: Flink Issue Type: Technical

[jira] [Created] (FLINK-37235) Add e2e test for flink-connector-elasticsearch8

Yanquan Lv created FLINK-37235: -- Summary: Add e2e test for flink-connector-elasticsearch8 Key: FLINK-37235 URL: https://issues.apache.org/jira/browse/FLINK-37235 Project: Flink Issue Type: Techn

[jira] [Created] (FLINK-37234) Add timeout for test case to avoid Infinite waiting

Yanquan Lv created FLINK-37234: -- Summary: Add timeout for test case to avoid Infinite waiting Key: FLINK-37234 URL: https://issues.apache.org/jira/browse/FLINK-37234 Project: Flink Issue Type:

[jira] [Created] (FLINK-37231) Add doc for newly added source metric statistics

Yanquan Lv created FLINK-37231: -- Summary: Add doc for newly added source metric statistics Key: FLINK-37231 URL: https://issues.apache.org/jira/browse/FLINK-37231 Project: Flink Issue Type: Tech

[jira] [Created] (FLINK-37224) Add the missing content of MongoDB CDC to the Chinese document.

Yanquan Lv created FLINK-37224: -- Summary: Add the missing content of MongoDB CDC to the Chinese document. Key: FLINK-37224 URL: https://issues.apache.org/jira/browse/FLINK-37224 Project: Flink

[jira] [Created] (FLINK-37223) Add the missing content of MySQL CDC to the Chinese document.

Yanquan Lv created FLINK-37223: -- Summary: Add the missing content of MySQL CDC to the Chinese document. Key: FLINK-37223 URL: https://issues.apache.org/jira/browse/FLINK-37223 Project: Flink Is

[jira] [Created] (FLINK-37210) Add flink-cdc-release-3.3.0 module to flink-cdc-migration-tests.

Yanquan Lv created FLINK-37210: -- Summary: Add flink-cdc-release-3.3.0 module to flink-cdc-migration-tests. Key: FLINK-37210 URL: https://issues.apache.org/jira/browse/FLINK-37210 Project: Flink

[jira] [Created] (FLINK-37209) Add Embedding AI Model for Qwen

Yanquan Lv created FLINK-37209: -- Summary: Add Embedding AI Model for Qwen Key: FLINK-37209 URL: https://issues.apache.org/jira/browse/FLINK-37209 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-37203) Support AltertableCommentEvent and AlterColumnCommentEvent.

Yanquan Lv created FLINK-37203: -- Summary: Support AltertableCommentEvent and AlterColumnCommentEvent. Key: FLINK-37203 URL: https://issues.apache.org/jira/browse/FLINK-37203 Project: Flink Issu

[jira] [Created] (FLINK-37200) Add e2e test for ElasticSearch Sink.

Yanquan Lv created FLINK-37200: -- Summary: Add e2e test for ElasticSearch Sink. Key: FLINK-37200 URL: https://issues.apache.org/jira/browse/FLINK-37200 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-37199) Update document in quickly start to guide user to add checkpoint configuration

Yanquan Lv created FLINK-37199: -- Summary: Update document in quickly start to guide user to add checkpoint configuration Key: FLINK-37199 URL: https://issues.apache.org/jira/browse/FLINK-37199 Project: F

[jira] [Created] (FLINK-37163) Add documents for recently merged PRs in FlinkCDC 3.3

Yanquan Lv created FLINK-37163: -- Summary: Add documents for recently merged PRs in FlinkCDC 3.3 Key: FLINK-37163 URL: https://issues.apache.org/jira/browse/FLINK-37163 Project: Flink Issue Type:

[jira] [Created] (FLINK-37162) Add Data Sources Documentation

Yanquan Lv created FLINK-37162: -- Summary: Add Data Sources Documentation Key: FLINK-37162 URL: https://issues.apache.org/jira/browse/FLINK-37162 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-37143) Update version of flink-connector-kafka to 4.0-SNAPSHOT

Yanquan Lv created FLINK-37143: -- Summary: Update version of flink-connector-kafka to 4.0-SNAPSHOT Key: FLINK-37143 URL: https://issues.apache.org/jira/browse/FLINK-37143 Project: Flink Issue Typ

[jira] [Created] (FLINK-37144) Update flink-connector-kafka version to 3.4-SNAPSHOT

Yanquan Lv created FLINK-37144: -- Summary: Update flink-connector-kafka version to 3.4-SNAPSHOT Key: FLINK-37144 URL: https://issues.apache.org/jira/browse/FLINK-37144 Project: Flink Issue Type:

[jira] [Created] (FLINK-37142) Update version of flink-connector-kafka to 4.0-SNAPSHOT

Yanquan Lv created FLINK-37142: -- Summary: Update version of flink-connector-kafka to 4.0-SNAPSHOT Key: FLINK-37142 URL: https://issues.apache.org/jira/browse/FLINK-37142 Project: Flink Issue Typ

[jira] [Created] (FLINK-37119) Bump the version of Paimon flink to 1.0.0

Yanquan Lv created FLINK-37119: -- Summary: Bump the version of Paimon flink to 1.0.0 Key: FLINK-37119 URL: https://issues.apache.org/jira/browse/FLINK-37119 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-37095) test case that used AI model may met quota not enough exception.

Yanquan Lv created FLINK-37095: -- Summary: test case that used AI model may met quota not enough exception. Key: FLINK-37095 URL: https://issues.apache.org/jira/browse/FLINK-37095 Project: Flink

[jira] [Created] (FLINK-36982) Failed to run pipeline if using `DATE_FORMAT(NOW(), 'yyyy-MM-dd') as datetime` in

Yanquan Lv created FLINK-36982: -- Summary: Failed to run pipeline if using `DATE_FORMAT(NOW(), '-MM-dd') as datetime` in Key: FLINK-36982 URL: https://issues.apache.org/jira/browse/FLINK-36982 Project

[jira] [Created] (FLINK-36964) Fix potential exception when SchemaChange in parallel with Paimon Sink.

Yanquan Lv created FLINK-36964: -- Summary: Fix potential exception when SchemaChange in parallel with Paimon Sink. Key: FLINK-36964 URL: https://issues.apache.org/jira/browse/FLINK-36964 Project: Flink

[jira] [Created] (FLINK-36923) Bump flink-connector-hbase to Flink 1.19

Yanquan Lv created FLINK-36923: -- Summary: Bump flink-connector-hbase to Flink 1.19 Key: FLINK-36923 URL: https://issues.apache.org/jira/browse/FLINK-36923 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-36913) Add an option in Kafka Sink to manual map table to topic name.

Yanquan Lv created FLINK-36913: -- Summary: Add an option in Kafka Sink to manual map table to topic name. Key: FLINK-36913 URL: https://issues.apache.org/jira/browse/FLINK-36913 Project: Flink I

[jira] [Created] (FLINK-36907) Bump flink-connector-aws to 1.20

Yanquan Lv created FLINK-36907: -- Summary: Bump flink-connector-aws to 1.20 Key: FLINK-36907 URL: https://issues.apache.org/jira/browse/FLINK-36907 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-36887) Add support for Flink 1.20 in Flink Hive connector

Yanquan Lv created FLINK-36887: -- Summary: Add support for Flink 1.20 in Flink Hive connector Key: FLINK-36887 URL: https://issues.apache.org/jira/browse/FLINK-36887 Project: Flink Issue Type: N

[jira] [Created] (FLINK-36877) Kafka Sink output canal-json format of deleted record is incorrect format.

Yanquan Lv created FLINK-36877: -- Summary: Kafka Sink output canal-json format of deleted record is incorrect format. Key: FLINK-36877 URL: https://issues.apache.org/jira/browse/FLINK-36877 Project: Flin

[jira] [Created] (FLINK-36852) Avoid StackOverflowError in Paimon Pipeline sink

Yanquan Lv created FLINK-36852: -- Summary: Avoid StackOverflowError in Paimon Pipeline sink Key: FLINK-36852 URL: https://issues.apache.org/jira/browse/FLINK-36852 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-36845) SourceTestSuiteBase/SinkTestSuiteBase will fail with `this operator belongs to is not initialized` error

Yanquan Lv created FLINK-36845: -- Summary: SourceTestSuiteBase/SinkTestSuiteBase will fail with `this operator belongs to is not initialized` error Key: FLINK-36845 URL: https://issues.apache.org/jira/browse/FLINK-368

[jira] [Created] (FLINK-36843) Remove deprecated method in flink-table-planner

Yanquan Lv created FLINK-36843: -- Summary: Remove deprecated method in flink-table-planner Key: FLINK-36843 URL: https://issues.apache.org/jira/browse/FLINK-36843 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-36832) Remove deprecated class in flink-connector-kafka

Yanquan Lv created FLINK-36832: -- Summary: Remove deprecated class in flink-connector-kafka Key: FLINK-36832 URL: https://issues.apache.org/jira/browse/FLINK-36832 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-36798) Improve data processing speed during the phase from snapshot to incremental phase

Yanquan Lv created FLINK-36798: -- Summary: Improve data processing speed during the phase from snapshot to incremental phase Key: FLINK-36798 URL: https://issues.apache.org/jira/browse/FLINK-36798 Project

[jira] [Created] (FLINK-36750) Paimon connector would reuse sequence number when schema evolution happened

Yanquan Lv created FLINK-36750: -- Summary: Paimon connector would reuse sequence number when schema evolution happened Key: FLINK-36750 URL: https://issues.apache.org/jira/browse/FLINK-36750 Project: Flin

[jira] [Created] (FLINK-36688) table.optimizer.reuse-source-enabled may cause disordered metadata columns when reading from Kafka.

Yanquan Lv created FLINK-36688: -- Summary: table.optimizer.reuse-source-enabled may cause disordered metadata columns when reading from Kafka. Key: FLINK-36688 URL: https://issues.apache.org/jira/browse/FLINK-36688

[jira] [Created] (FLINK-36682) Add split assign strategy to avoid OOM error in TaskManager

Yanquan Lv created FLINK-36682: -- Summary: Add split assign strategy to avoid OOM error in TaskManager Key: FLINK-36682 URL: https://issues.apache.org/jira/browse/FLINK-36682 Project: Flink Issu