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

[ https://issues.apache.org/jira/browse/FLINK-37234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-37234. Resolution: Fixed Fixed via master(3.3-SNAPSHOT): 81e6a4a329498ddd9ff63d9db8ddbcf22882a7fc > Add

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

[ https://issues.apache.org/jira/browse/FLINK-37234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37234: -- Assignee: Yanquan Lv > Add timeout for test case to avoid Infinite waiting > ---

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

[ https://issues.apache.org/jira/browse/FLINK-37231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-37231. Resolution: Fixed via master: 7717779ebff3d5900c3adcd06bc860949d543f97 > Add doc for newly added

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

[ https://issues.apache.org/jira/browse/FLINK-37231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37231: -- Assignee: Yanquan Lv > Add doc for newly added source metric statistics > ---

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

[ https://issues.apache.org/jira/browse/FLINK-37251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37251: -- Assignee: Yanquan Lv > Add download link for pipeline connector. > -

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

[ https://issues.apache.org/jira/browse/FLINK-37251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-37251. Resolution: Implemented Implemented via master: 8d54be65c01a07c73b361a744b76cf51e4760027 > Add do

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

[ https://issues.apache.org/jira/browse/FLINK-37163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-37163. -- Resolution: Fixed > Add documents for recently merged PRs in FlinkCDC 3.3 > --

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

[ https://issues.apache.org/jira/browse/FLINK-37224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-37224. Resolution: Resolved Resolved via master: 6aeb5e8c9fb2a59b46adc3bf2349a59e9deac2f7 > Add the miss

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

[ https://issues.apache.org/jira/browse/FLINK-37224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37224: -- Assignee: Yanquan Lv > Add the missing content of MongoDB CDC to the Chinese document. >

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

[ https://issues.apache.org/jira/browse/FLINK-37252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-37252. Resolution: Fixed Fixed via master: 1fa762dd632dfa8cf52bbe491e2e42ce44860e38 > Align Chinese docu

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

[ https://issues.apache.org/jira/browse/FLINK-37252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37252: -- Assignee: Yanquan Lv > Align Chinese document of Postgres CDC Connector with English document

[jira] [Resolved] (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 ] Leonard Xu resolved FLINK-34729. Resolution: Resolved Resolved via master: d1d334d13a18a58b6997caaef35c764bc2ca13d6 > "Core Concep

[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 ] Leonard Xu updated FLINK-34729: --- Affects Version/s: cdc-3.3.0 > "Core Concept" Pages for Flink CDC Chinese Documentation > --

[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 ] Leonard Xu updated FLINK-34729: --- Fix Version/s: cdc-3.4.0 > "Core Concept" Pages for Flink CDC Chinese Documentation > --

[jira] [Assigned] (FLINK-37254) Flink CDC OceanBase Connector Throws Exception for Column Default Value ‘DEFAULT ‘0’

[ https://issues.apache.org/jira/browse/FLINK-37254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37254: -- Assignee: He Wang > Flink CDC OceanBase Connector Throws Exception for Column Default Value

[jira] [Commented] (FLINK-37254) flink cdc的oceanbase cdc 存在表字段的默认值为default '0'抛出异常

[ https://issues.apache.org/jira/browse/FLINK-37254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923920#comment-17923920 ] Leonard Xu commented on FLINK-37254: Thanks [~weigphf]for the reporting and [~wanghe

[jira] [Assigned] (FLINK-35713) Add sink PARALLELISM for flink-cdc

[ https://issues.apache.org/jira/browse/FLINK-35713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35713: -- Assignee: ChaomingZhang > Add sink PARALLELISM for flink-cdc > --

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

[ https://issues.apache.org/jira/browse/FLINK-37203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37203: -- Assignee: ChaomingZhang > Support AltertableCommentEvent and AlterColumnCommentEvent. > -

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

[ https://issues.apache.org/jira/browse/FLINK-37209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37209: -- Assignee: Yanquan Lv > Add Embedding AI Model for Qwen > --- > >

[jira] [Commented] (FLINK-36061) Support Apache iceberg for pipeline connector

[ https://issues.apache.org/jira/browse/FLINK-36061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916295#comment-17916295 ] Leonard Xu commented on FLINK-36061: Splitting the connector development into two p

[jira] [Assigned] (FLINK-36061) Support Apache iceberg for pipeline connector

[ https://issues.apache.org/jira/browse/FLINK-36061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-36061: -- Assignee: ZhengYu Chen > Support Apache iceberg for pipeline connector >

[jira] [Assigned] (FLINK-37204) Add missing StarRocks connector options for 1.2.10.

[ https://issues.apache.org/jira/browse/FLINK-37204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37204: -- Assignee: ChaomingZhang > Add missing StarRocks connector options for 1.2.10. > -

[jira] [Commented] (FLINK-36061) Support Apache iceberg for pipeline connector

[ https://issues.apache.org/jira/browse/FLINK-36061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916250#comment-17916250 ] Leonard Xu commented on FLINK-36061: [~melin] +1 for your proposal, compaction optim

[jira] [Commented] (FLINK-36061) Support Apache iceberg for pipeline connector

[ https://issues.apache.org/jira/browse/FLINK-36061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916248#comment-17916248 ] Leonard Xu commented on FLINK-36061: [~rmoff]You're right, this is a duplicated issu

[jira] [Resolved] (FLINK-36061) Support Apache iceberg for pipeline connector

[ https://issues.apache.org/jira/browse/FLINK-36061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36061. Resolution: Duplicate > Support Apache iceberg for pipeline connector > --

[jira] [Commented] (FLINK-35671) Support Iceberg CDC Pipeline Sink

[ https://issues.apache.org/jira/browse/FLINK-35671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916246#comment-17916246 ] Leonard Xu commented on FLINK-35671: Hey [~m.orazow] , do you have time to work for

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

[ https://issues.apache.org/jira/browse/FLINK-37200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37200: -- Assignee: Yanquan Lv > Add e2e test for ElasticSearch Sink. > ---

[jira] [Assigned] (FLINK-37201) FlinkCDC Pipeline transform arithmetic functions support parameters of null and more numerical types.

[ https://issues.apache.org/jira/browse/FLINK-37201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37201: -- Assignee: Wenkai Qi > FlinkCDC Pipeline transform arithmetic functions support parameters of

[jira] [Assigned] (FLINK-37191) MySQL 'Compile and test' stage timeout after 90 minutes

[ https://issues.apache.org/jira/browse/FLINK-37191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37191: -- Assignee: yux > MySQL 'Compile and test' stage timeout after 90 minutes > ---

[jira] [Updated] (FLINK-35623) Bump mongo-driver version from 4.7.2 to 5.1.1 to support MongoDB 7.0

[ https://issues.apache.org/jira/browse/FLINK-35623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35623: --- Fix Version/s: mongodb-2.0.0 (was: mongodb-1.3.0) > Bump mongo-driver version

[jira] [Updated] (FLINK-34216) Support fine-grained configuration to control filter push down for MongoDB Connector

[ https://issues.apache.org/jira/browse/FLINK-34216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-34216: --- Fix Version/s: mongodb-2.0.0 (was: mongodb-1.3.0) > Support fine-grained conf

[jira] [Updated] (FLINK-35616) Support upsert into sharded collections for MongoRowDataSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-35616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35616: --- Fix Version/s: mongodb-2.0.0 (was: mongodb-1.3.0) > Support upsert into shard

[jira] [Updated] (FLINK-36075) Add paginate partition strategy for mongodb connector

[ https://issues.apache.org/jira/browse/FLINK-36075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-36075: --- Fix Version/s: mongodb-2.0.0 (was: mongodb-1.3.0) > Add paginate partition st

[jira] [Updated] (FLINK-34214) FLIP-377: Support fine-grained configuration to control filter push down for Table/SQL Sources

[ https://issues.apache.org/jira/browse/FLINK-34214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-34214: --- Fix Version/s: mongodb-2.0.0 (was: mongodb-1.3.0) > FLIP-377: Support fine-gr

[jira] [Updated] (FLINK-36074) Support insert overwrite semantics for mongodb table sink

[ https://issues.apache.org/jira/browse/FLINK-36074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-36074: --- Fix Version/s: mongodb-2.0.0 (was: mongodb-1.3.0) > Support insert overwrite

[jira] [Updated] (FLINK-35975) MongoFilterPushDownVisitorTest fails

[ https://issues.apache.org/jira/browse/FLINK-35975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35975: --- Fix Version/s: mongodb-2.0.0 (was: mongodb-1.3.0) > MongoFilterPushDownVisito

[jira] [Updated] (FLINK-36053) Support multi-version integration test in mongodb connector

[ https://issues.apache.org/jira/browse/FLINK-36053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-36053: --- Fix Version/s: mongodb-2.0.0 (was: mongodb-1.3.0) > Support multi-version int

[jira] [Updated] (FLINK-36738) Weekly CI for MongoDB connector fails on jdk21

[ https://issues.apache.org/jira/browse/FLINK-36738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-36738: --- Fix Version/s: mongodb-2.0.0 (was: mongodb-1.3.0) > Weekly CI for MongoDB con

[jira] [Created] (FLINK-37191) MySQL 'Compile and test' stage timeout after 90 minutes

Leonard Xu created FLINK-37191: -- Summary: MySQL 'Compile and test' stage timeout after 90 minutes Key: FLINK-37191 URL: https://issues.apache.org/jira/browse/FLINK-37191 Project: Flink Issue Typ

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

[ https://issues.apache.org/jira/browse/FLINK-37163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37163: -- Assignee: Yanquan Lv > Add documents for recently merged PRs in FlinkCDC 3.3 > --

[jira] [Assigned] (FLINK-37162) Add Data Sink Documentation

[ https://issues.apache.org/jira/browse/FLINK-37162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37162: -- Assignee: Yanquan Lv > Add Data Sink Documentation > --- > >

[jira] [Updated] (FLINK-36713) NoSuchMethodError: PostgresConnection with PostgresIncrementalSource ar runtime

[ https://issues.apache.org/jira/browse/FLINK-36713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-36713: --- Fix Version/s: cdc-3.3.1 (was: cdc-3.3.0) > NoSuchMethodError: PostgresConnec

[jira] [Updated] (FLINK-34865) [enhancement] [StarRocks] When synchronizing tables using Flink CDC 3.x, is it possible to include the comments of the source table's fields when creating the target tab

[ https://issues.apache.org/jira/browse/FLINK-34865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-34865: --- Affects Version/s: (was: cdc-3.4.0) > [enhancement] [StarRocks] When synchronizing tables using

[jira] [Updated] (FLINK-34865) [enhancement] [StarRocks] When synchronizing tables using Flink CDC 3.x, is it possible to include the comments of the source table's fields when creating the target tab

[ https://issues.apache.org/jira/browse/FLINK-34865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-34865: --- Affects Version/s: cdc-3.4.0 > [enhancement] [StarRocks] When synchronizing tables using Flink CDC 3

[jira] [Comment Edited] (FLINK-34865) [enhancement] [StarRocks] When synchronizing tables using Flink CDC 3.x, is it possible to include the comments of the source table's fields when creating the tar

[ https://issues.apache.org/jira/browse/FLINK-34865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913517#comment-17913517 ] Leonard Xu edited comment on FLINK-34865 at 1/17/25 2:53 AM: -

[jira] [Updated] (FLINK-36578) Fixed bug when converting json type data to string

[ https://issues.apache.org/jira/browse/FLINK-36578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-36578: --- Summary: Fixed bug when converting json type data to string (was: Fixed bug when converting json to

[jira] [Updated] (FLINK-36578) Fixed inconsistent format when converting json type data to string

[ https://issues.apache.org/jira/browse/FLINK-36578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-36578: --- Summary: Fixed inconsistent format when converting json type data to string (was: Fixed bug when c

[jira] [Resolved] (FLINK-36578) Fixed bug when converting json to string

[ https://issues.apache.org/jira/browse/FLINK-36578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36578. Resolution: Fixed Fixed via master(3.3-SNAPSHOT): a1c9c19d7d378a2de5044e79516630b5baaf9cc6 > Fixe

[jira] [Assigned] (FLINK-36578) Fixed bug when converting json to string

[ https://issues.apache.org/jira/browse/FLINK-36578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-36578: -- Assignee: Lee SeungMin > Fixed bug when converting json to string > -

[jira] [Resolved] (FLINK-37122) NoSuchMethodError occurs when using flink 1.18.1.

[ https://issues.apache.org/jira/browse/FLINK-37122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-37122. Fix Version/s: cdc-3.3.0 Resolution: Implemented via master: 947dffca3182722340048c913c286e

[jira] [Updated] (FLINK-37122) NoSuchMethodError occurs when using flink 1.18.1.

[ https://issues.apache.org/jira/browse/FLINK-37122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37122: --- Issue Type: Improvement (was: Bug) > NoSuchMethodError occurs when using flink 1.18.1. > --

[jira] [Resolved] (FLINK-35067) Support metadata 'op_type' virtual column for Postgres CDC Connector.

[ https://issues.apache.org/jira/browse/FLINK-35067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35067. Resolution: Implemented Implemented via master: 7997f51c559690fe70aee0d14e40590a43d910ee > Supp

[jira] [Assigned] (FLINK-35067) Support metadata 'op_type' virtual column for Postgres CDC Connector.

[ https://issues.apache.org/jira/browse/FLINK-35067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35067: -- Assignee: Leonard Xu (was: Muhammet Orazov) > Support metadata 'op_type' virtual column for

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

[ https://issues.apache.org/jira/browse/FLINK-36913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36913. Resolution: Implemented Implemented via master: a16abd5d243fdf045cf1ed1be734b14dcc11458b > Add an

[jira] [Resolved] (FLINK-35600) Data read duplication during the full-to-incremental conversion phase

[ https://issues.apache.org/jira/browse/FLINK-35600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35600. Resolution: Fixed Fixed via master: 2fa215e5c45818ecc7f5d73783dfb61c1f0e4828 > Data read duplicat

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

[ https://issues.apache.org/jira/browse/FLINK-35802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35802: -- Assignee: Yanquan Lv (was: ruofan) > Deadlock may happen after adding new tables > -

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

[ https://issues.apache.org/jira/browse/FLINK-35802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35802. Resolution: Fixed Fixed via master: afd4a74c0a3dc4f6353a37e875023a7f849a634e > Deadlock may happe

[jira] [Assigned] (FLINK-36351) Doris pipeline sink does not support Flink TIME type

[ https://issues.apache.org/jira/browse/FLINK-36351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-36351: -- Assignee: vinlee19 > Doris pipeline sink does not support Flink TIME type > -

[jira] [Resolved] (FLINK-36351) Doris pipeline sink does not support Flink TIME type

[ https://issues.apache.org/jira/browse/FLINK-36351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36351. Resolution: Implemented Implemented via master: 177da16facb1773f44020ef4f0f85f15a31d964a > Doris

[jira] [Comment Edited] (FLINK-36620) Add support for the flink-home parameter to be set in both “--flink-home $FLINK_HOME” and “--flink-home=$FLINK_HOME” formats

[ https://issues.apache.org/jira/browse/FLINK-36620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913648#comment-17913648 ] Leonard Xu edited comment on FLINK-36620 at 1/16/25 10:09 AM:

[jira] [Resolved] (FLINK-36620) Add support for the flink-home parameter to be set in both “--flink-home $FLINK_HOME” and “--flink-home=$FLINK_HOME” formats

[ https://issues.apache.org/jira/browse/FLINK-36620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36620. Resolution: Resolved > Add support for the flink-home parameter to be set in both “--flink-home >

[jira] [Resolved] (FLINK-36620) Add support for the flink-home parameter to be set in both “--flink-home $FLINK_HOME” and “--flink-home=$FLINK_HOME” formats

[ https://issues.apache.org/jira/browse/FLINK-36620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36620. Resolution: Fixed Fixed via 6b13868dd5ac7474c946bdc41005feed616d9be8 > Add support for the flink-

[jira] [Reopened] (FLINK-36620) Add support for the flink-home parameter to be set in both “--flink-home $FLINK_HOME” and “--flink-home=$FLINK_HOME” formats

[ https://issues.apache.org/jira/browse/FLINK-36620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reopened FLINK-36620: > Add support for the flink-home parameter to be set in both “--flink-home > $FLINK_HOME” and “--flin

[jira] [Assigned] (FLINK-36620) Add support for the flink-home parameter to be set in both “--flink-home $FLINK_HOME” and “--flink-home=$FLINK_HOME” formats

[ https://issues.apache.org/jira/browse/FLINK-36620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-36620: -- Assignee: zjjiang > Add support for the flink-home parameter to be set in both “--flink-home

[jira] [Resolved] (FLINK-36224) Add the version mapping between pipeline connectors and flink

[ https://issues.apache.org/jira/browse/FLINK-36224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36224. Resolution: Resolved Resolved in master: 087195a3a60802179543012242144714cdcca156 > Add the vers

[jira] [Assigned] (FLINK-36224) Add the version mapping between pipeline connectors and flink

[ https://issues.apache.org/jira/browse/FLINK-36224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-36224: -- Assignee: Thorne > Add the version mapping between pipeline connectors and flink > -

[jira] [Resolved] (FLINK-36406) MetadataApplier should be closed when the job stop

[ https://issues.apache.org/jira/browse/FLINK-36406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36406. Assignee: Sergei Morozov Resolution: Fixed Fixed via master(3.3-SNAPSHOT): 5691b7bf977abd608

[jira] [Updated] (FLINK-36754) When projection is empty or null, it is treated as an asterisk

[ https://issues.apache.org/jira/browse/FLINK-36754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-36754: --- Fix Version/s: cdc-3.3.0 > When projection is empty or null, it is treated as an asterisk >

[jira] [Resolved] (FLINK-36754) When projection is empty or null, it is treated as an asterisk

[ https://issues.apache.org/jira/browse/FLINK-36754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36754. Resolution: Implemented Resolved via master: d83ccbeeb45bc0d9a430f6c1988691b6eb636314 > When proj

[jira] [Assigned] (FLINK-36754) When projection is empty or null, it is treated as an asterisk

[ https://issues.apache.org/jira/browse/FLINK-36754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-36754: -- Assignee: MOBIN > When projection is empty or null, it is treated as an asterisk > --

[jira] [Assigned] (FLINK-37144) Update flink-connector-kafka version to 4.0-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-37144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37144: -- Assignee: Yanquan Lv > Update flink-connector-kafka version to 4.0-SNAPSHOT > ---

[jira] [Resolved] (FLINK-37124) Simplify the print log in Flink CDC schema Coordinator

[ https://issues.apache.org/jira/browse/FLINK-37124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-37124. Resolution: Fixed Resolved via master: e2b8f70e0def66091c29fd8e5b75ccdfabfda932 > Simplify the pr

[jira] [Updated] (FLINK-37124) Simplify the print log in Flink CDC schema Coordinator

[ https://issues.apache.org/jira/browse/FLINK-37124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37124: --- Fix Version/s: cdc-3.3.0 > Simplify the print log in Flink CDC schema Coordinator >

[jira] [Resolved] (FLINK-34865) [enhancement] [StarRocks] When synchronizing tables using Flink CDC 3.x, is it possible to include the comments of the source table's fields when creating the target ta

[ https://issues.apache.org/jira/browse/FLINK-34865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-34865. Fix Version/s: cdc-3.3.0 Resolution: Fixed Fixed via master: b5d9673258069ec05eceb2b68eeaf8

[jira] [Updated] (FLINK-34865) [enhancement] [StarRocks] When synchronizing tables using Flink CDC 3.x, is it possible to include the comments of the source table's fields when creating the target tab

[ https://issues.apache.org/jira/browse/FLINK-34865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-34865: --- Affects Version/s: cdc-3.2.1 > [enhancement] [StarRocks] When synchronizing tables using Flink CDC 3

[jira] [Updated] (FLINK-36647) Support TimestampDiff function in cdc pipeline transform

[ https://issues.apache.org/jira/browse/FLINK-36647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-36647: --- Issue Type: New Feature (was: Improvement) > Support TimestampDiff function in cdc pipeline transfo

[jira] [Comment Edited] (FLINK-36647) Support TimestampDiff function in cdc pipeline transform

[ https://issues.apache.org/jira/browse/FLINK-36647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913516#comment-17913516 ] Leonard Xu edited comment on FLINK-36647 at 1/16/25 2:07 AM: -

[jira] [Resolved] (FLINK-36647) Support TimestampDiff function in cdc pipeline transform

[ https://issues.apache.org/jira/browse/FLINK-36647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36647. Resolution: Fixed Fixed via master: d77cf7fa759d64f257f67c4a9b713893cec84f5c > Support TimestampD

[jira] [Reopened] (FLINK-36647) Support TimestampDiff function in cdc pipeline transform

[ https://issues.apache.org/jira/browse/FLINK-36647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reopened FLINK-36647: > Support TimestampDiff function in cdc pipeline transform > -

[jira] [Resolved] (FLINK-36647) Support TimestampDiff function in cdc pipeline transform

[ https://issues.apache.org/jira/browse/FLINK-36647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36647. Resolution: Implemented > Support TimestampDiff function in cdc pipeline transform > -

[jira] [Assigned] (FLINK-37124) Simplify the print log in Flink CDC schema Coordinator

[ https://issues.apache.org/jira/browse/FLINK-37124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37124: -- Assignee: yux > Simplify the print log in Flink CDC schema Coordinator >

[jira] [Updated] (FLINK-36741) The precision of Decimal has been lost when use FlinkCDC transform

[ https://issues.apache.org/jira/browse/FLINK-36741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-36741: --- Fix Version/s: cdc-3.3.0 > The precision of Decimal has been lost when use FlinkCDC transform > ---

[jira] [Assigned] (FLINK-36741) The precision of Decimal has been lost when use FlinkCDC transform

[ https://issues.apache.org/jira/browse/FLINK-36741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-36741: -- Assignee: Wenkai Qi > The precision of Decimal has been lost when use FlinkCDC transform > -

[jira] [Resolved] (FLINK-36741) The precision of Decimal has been lost when use FlinkCDC transform

[ https://issues.apache.org/jira/browse/FLINK-36741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36741. Resolution: Fixed Fixed via master: 79e868b86483b66e83edc22f060e57c3a68bae9b > The precision of D

[jira] [Created] (FLINK-37124) Simplify the print log in Flink CDC schema Coordinator

Leonard Xu created FLINK-37124: -- Summary: Simplify the print log in Flink CDC schema Coordinator Key: FLINK-37124 URL: https://issues.apache.org/jira/browse/FLINK-37124 Project: Flink Issue Type

[jira] [Resolved] (FLINK-36977) paimon apply default value options when apply add column_schema change

[ https://issues.apache.org/jira/browse/FLINK-36977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36977. Resolution: Fixed fixed via master: 8b554458d331913e32adbad523d4e140b1681689 > paimon apply defau

[jira] [Assigned] (FLINK-36977) paimon apply default value options when apply add column_schema change

[ https://issues.apache.org/jira/browse/FLINK-36977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-36977: -- Assignee: hiliuxg > paimon apply default value options when apply add column_schema change >

[jira] [Assigned] (FLINK-37123) FlinkCDC YAML supports TIMESTAMP_TZ

[ https://issues.apache.org/jira/browse/FLINK-37123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37123: -- Assignee: Wenkai Qi > FlinkCDC YAML supports TIMESTAMP_TZ > -

[jira] [Commented] (FLINK-37123) FlinkCDC YAML supports TIMESTAMP_TZ

[ https://issues.apache.org/jira/browse/FLINK-37123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912934#comment-17912934 ] Leonard Xu commented on FLINK-37123: Thanks [~wink] for filing this ticket, We'd bet

[jira] [Commented] (FLINK-37122) NoSuchMethodError occurs when using flink 1.18.1.

[ https://issues.apache.org/jira/browse/FLINK-37122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912919#comment-17912919 ] Leonard Xu commented on FLINK-37122: We have bump flink version to 1.19 via https:/

[jira] [Assigned] (FLINK-37122) NoSuchMethodError occurs when using flink 1.18.1.

[ https://issues.apache.org/jira/browse/FLINK-37122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37122: -- Assignee: ChaomingZhang > NoSuchMethodError occurs when using flink 1.18.1. > ---

[jira] [Updated] (FLINK-36636) Timestamp data can not be compared in cdc pipeline transform

[ https://issues.apache.org/jira/browse/FLINK-36636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-36636: --- Affects Version/s: cdc-3.2.1 (was: cdc-3.2.0) > Timestamp data can not be

[jira] [Resolved] (FLINK-36636) Timestamp data can not be compared in cdc pipeline transform

[ https://issues.apache.org/jira/browse/FLINK-36636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36636. Resolution: Fixed Fixed via master: 551bdf395daf33588f5df86dd8450d23a844128e > Timestamp data can

[jira] [Updated] (FLINK-36636) Timestamp data can not be compared in cdc pipeline transform

[ https://issues.apache.org/jira/browse/FLINK-36636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-36636: --- Fix Version/s: cdc-3.3.0 > Timestamp data can not be compared in cdc pipeline transform > --

[jira] [Resolved] (FLINK-35387) PG CDC source support heart beat

[ https://issues.apache.org/jira/browse/FLINK-35387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35387. Resolution: Implemented Implemented via master: bcd70df85c0aeefd782a04be7b930838f69e20f0 > PG CDC

[jira] [Updated] (FLINK-35387) PG CDC source support heart beat

[ https://issues.apache.org/jira/browse/FLINK-35387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35387: --- Issue Type: New Feature (was: Bug) > PG CDC source support heart beat > ---

[jira] [Resolved] (FLINK-36974) support overwrite flink config by command line

[ https://issues.apache.org/jira/browse/FLINK-36974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36974. Resolution: Implemented via master: 6b65aed4c5da3284214a08082e01b4768aabb67c > support overwrite

[jira] [Assigned] (FLINK-36974) support overwrite flink config by command line

[ https://issues.apache.org/jira/browse/FLINK-36974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-36974: -- Assignee: hiliuxg > support overwrite flink config by command line > ---

[jira] [Assigned] (FLINK-37093) The catalog that failed validation due to no type still exists in catalogStoreHolder

[ https://issues.apache.org/jira/browse/FLINK-37093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37093: -- Assignee: Mingcan Wang > The catalog that failed validation due to no type still exists in >

[jira] [Assigned] (FLINK-37121) Wrong syntax and examples in create table statement doc

[ https://issues.apache.org/jira/browse/FLINK-37121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37121: -- Assignee: Mingcan Wang > Wrong syntax and examples in create table statement doc > --

  1   2   3   4   5   6   7   8   9   10   >