[jira] [Updated] (FLINK-37304) Dynamic Kafka Source logs unncessary information in plaintext under INFO

[ https://issues.apache.org/jira/browse/FLINK-37304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37304: --- Summary: Dynamic Kafka Source logs unncessary information in plaintext under INFO (was: Dynamic Kaf

[jira] [Updated] (FLINK-37304) Dynamic Kafka Source logs unncessary information in plaintext under INFO

[ https://issues.apache.org/jira/browse/FLINK-37304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37304: --- Description: The new Flink Dynamic Kafka Source logs unncessary in plaintext under INFO. Specifical

[jira] [Updated] (FLINK-37304) Dynamic Kafka Source logs unnecessary information in plaintext under INFO

[ https://issues.apache.org/jira/browse/FLINK-37304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37304: --- Summary: Dynamic Kafka Source logs unnecessary information in plaintext under INFO (was: Dynamic Ka

[jira] [Updated] (FLINK-37304) Dynamic Kafka Source logs unncessary information in plaintext under INFO

[ https://issues.apache.org/jira/browse/FLINK-37304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37304: --- Description: The new Flink Dynamic Kafka Source logs unnecessary in plaintext under INFO. Specifica

[jira] [Assigned] (FLINK-37305) JDBC Connector CI failed due to network issue

[ https://issues.apache.org/jira/browse/FLINK-37305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37305: -- Assignee: yux > JDBC Connector CI failed due to network issue > -

[jira] [Commented] (FLINK-37306) Flink CDC CI failed due to timezone shift

[ https://issues.apache.org/jira/browse/FLINK-37306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926250#comment-17926250 ] Leonard Xu commented on FLINK-37306: [~Lv Yanquan]Would you like to investigate this

[jira] [Created] (FLINK-37306) Flink CDC CI failed due to timezone shift

Leonard Xu created FLINK-37306: -- Summary: Flink CDC CI failed due to timezone shift Key: FLINK-37306 URL: https://issues.apache.org/jira/browse/FLINK-37306 Project: Flink Issue Type: Bug Aff

[jira] [Updated] (FLINK-37305) JDBC Connector CI failed due to network issue

[ https://issues.apache.org/jira/browse/FLINK-37305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37305: --- Labels: newbiee (was: ) > JDBC Connector CI failed due to network issue > -

[jira] [Created] (FLINK-37305) JDBC Connector CI failed due to network issue

Leonard Xu created FLINK-37305: -- Summary: JDBC Connector CI failed due to network issue Key: FLINK-37305 URL: https://issues.apache.org/jira/browse/FLINK-37305 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-37304) Dynamic Kafka Source logs credentials in plaintext under INFO

[ https://issues.apache.org/jira/browse/FLINK-37304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926247#comment-17926247 ] Leonard Xu commented on FLINK-37304: Thanks [~kunni] for the quick response! assigne

[jira] [Assigned] (FLINK-37304) Dynamic Kafka Source logs credentials in plaintext under INFO

[ https://issues.apache.org/jira/browse/FLINK-37304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37304: -- Assignee: Yanquan Lv > Dynamic Kafka Source logs credentials in plaintext under INFO > --

[jira] [Updated] (FLINK-37304) Dynamic Kafka Source logs credentials in plaintext under INFO

[ https://issues.apache.org/jira/browse/FLINK-37304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37304: --- Priority: Blocker (was: Major) > Dynamic Kafka Source logs credentials in plaintext under INFO > --

[jira] [Created] (FLINK-37304) Dynamic Kafka Source logs credentials in plaintext under INFO

Leonard Xu created FLINK-37304: -- Summary: Dynamic Kafka Source logs credentials in plaintext under INFO Key: FLINK-37304 URL: https://issues.apache.org/jira/browse/FLINK-37304 Project: Flink Is

[jira] [Assigned] (FLINK-37300) Add database native type information to Column struct to generate ddl correctly

[ https://issues.apache.org/jira/browse/FLINK-37300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37300: -- Assignee: He Wang > Add database native type information to Column struct to generate ddl >

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

[ https://issues.apache.org/jira/browse/FLINK-36564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925979#comment-17925979 ] Leonard Xu edited comment on FLINK-36564 at 2/11/25 12:27 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-36564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36564. Resolution: Fixed Fixed via master: b44e5708b84e2de8bd9dc6e5e1e7d5b5bf1926e8 > Running CI in rand

[jira] [Resolved] (FLINK-37262) MySQL CDC connector could not configure the `scan.parse.online.schema.changes.enabled` option

[ https://issues.apache.org/jira/browse/FLINK-37262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-37262. Resolution: Fixed Fixed via master: 0a4c256433c60b8a43ccc412d38f35904d0b5448 > MySQL CDC connecto

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

[ https://issues.apache.org/jira/browse/FLINK-36564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36564. Resolution: Resolved > Running CI in random timezone to expose more time related bugs > -

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

[ https://issues.apache.org/jira/browse/FLINK-36564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reopened FLINK-36564: > Running CI in random timezone to expose more time related bugs > --

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

[ https://issues.apache.org/jira/browse/FLINK-36564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-36564: -- Assignee: Yanquan Lv > Running CI in random timezone to expose more time related bugs >

[jira] [Resolved] (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 resolved FLINK-37191. Resolution: Fixed Fixed via master: cd1fb6f980ee776216c444eb99acea90b61b8169 > MySQL 'Compile and

[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: Yanquan Lv (was: yux) > MySQL 'Compile and test' stage timeout after 90 minutes >

[jira] [Assigned] (FLINK-37262) MySQL CDC connector could not configure the `scan.parse.online.schema.changes.enabled` option

[ https://issues.apache.org/jira/browse/FLINK-37262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37262: -- Assignee: yux > MySQL CDC connector could not configure the > `scan.parse.online.schema.chan

[jira] [Updated] (FLINK-37262) MySQL CDC connector could not configure the `scan.parse.online.schema.changes.enabled` option

[ https://issues.apache.org/jira/browse/FLINK-37262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37262: --- Fix Version/s: cdc-3.4.0 > MySQL CDC connector could not configure the > `scan.parse.online.schema.

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

[ https://issues.apache.org/jira/browse/FLINK-36682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36682. Resolution: Duplicate Duplicated with FLINK-37120 as FLINK-37120 proposed a better solution for th

[jira] [Assigned] (FLINK-37120) MySqlSnapshotSplitAssigner assign the ending chunk early to avoid TaskManager OOM

[ https://issues.apache.org/jira/browse/FLINK-37120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37120: -- Assignee: JunboWang > MySqlSnapshotSplitAssigner assign the ending chunk early to avoid TaskM

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

[ https://issues.apache.org/jira/browse/FLINK-36682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-36682: -- Assignee: Yanquan Lv > Add split assign strategy to avoid OOM error in TaskManager >

[jira] [Resolved] (FLINK-37287) There was Apache Paimon 0.9, but it is gone.

[ https://issues.apache.org/jira/browse/FLINK-37287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-37287. Resolution: Fixed Fixed via master: 508dc51ccf51f8cdf488f08e2366c8b1b227bd89 > There was Apache P

[jira] [Updated] (FLINK-37287) There was Apache Paimon 0.9, but it is gone.

[ https://issues.apache.org/jira/browse/FLINK-37287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37287: --- Component/s: Documentation > There was Apache Paimon 0.9, but it is gone. >

[jira] [Updated] (FLINK-37287) There was Apache Paimon 0.9, but it is gone.

[ https://issues.apache.org/jira/browse/FLINK-37287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37287: --- Priority: Minor (was: Major) > There was Apache Paimon 0.9, but it is gone. > -

[jira] [Updated] (FLINK-37287) There was Apache Paimon 0.9, but it is gone.

[ https://issues.apache.org/jira/browse/FLINK-37287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37287: --- Affects Version/s: cdc-3.3.0 (was: cdc-3.4.0) > There was Apache Paimon 0

[jira] [Assigned] (FLINK-37287) There was Apache Paimon 0.9, but it is gone.

[ https://issues.apache.org/jira/browse/FLINK-37287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37287: -- Assignee: 911432 > There was Apache Paimon 0.9, but it is gone. > ---

[jira] [Commented] (FLINK-25029) Hadoop Caller Context Setting In Flink

[ https://issues.apache.org/jira/browse/FLINK-25029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925530#comment-17925530 ] Leonard Xu commented on FLINK-25029: Assigned to [~ZhenqiuHuang] after being staled

[jira] [Assigned] (FLINK-25029) Hadoop Caller Context Setting In Flink

[ https://issues.apache.org/jira/browse/FLINK-25029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-25029: -- Assignee: Zhenqiu Huang (was: Leonard Xu) > Hadoop Caller Context Setting In Flink > ---

[jira] [Assigned] (FLINK-25029) Hadoop Caller Context Setting In Flink

[ https://issues.apache.org/jira/browse/FLINK-25029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-25029: -- Assignee: Leonard Xu (was: chenfengLiu) > Hadoop Caller Context Setting In Flink > -

[jira] [Assigned] (FLINK-36604) StreamingJobGraphGenerator::setOperatorConfig checks input serializer lengh

[ https://issues.apache.org/jira/browse/FLINK-36604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-36604: -- Assignee: Mingliang Liu > StreamingJobGraphGenerator::setOperatorConfig checks input serializ

[jira] [Assigned] (FLINK-37292) The Flink-Kubernetes dependency embedded in the packaging of flink-cdc-dist is incompatible with Flink 1.20.

[ https://issues.apache.org/jira/browse/FLINK-37292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37292: -- Assignee: Wenkai Qi > The Flink-Kubernetes dependency embedded in the packaging of flink-cdc-

[jira] [Assigned] (FLINK-37283) Improved ability to split ‘db.\.*.\.*.’

[ https://issues.apache.org/jira/browse/FLINK-37283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37283: -- Assignee: ouyangwulin > Improved ability to split ‘db.\.*.\.*.’ > ---

[jira] [Updated] (FLINK-36698) Elasticsearch Pipeline Connector support index sharding

[ https://issues.apache.org/jira/browse/FLINK-36698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-36698: --- Affects Version/s: cdc-3.3.0 > Elasticsearch Pipeline Connector support index sharding > ---

[jira] [Resolved] (FLINK-36698) Elasticsearch Pipeline Connector support index sharding

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

[jira] [Updated] (FLINK-36698) Elasticsearch Pipeline Connector support index sharding

[ https://issues.apache.org/jira/browse/FLINK-36698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-36698: --- Fix Version/s: cdc-3.4.0 > Elasticsearch Pipeline Connector support index sharding > ---

[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] [Commented] (FLINK-36167) testSinkDisorderChangeLog failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-36167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913945#comment-17913945 ] Shuai Xu commented on FLINK-36167: -- I would like try to fix it. Could you assign it to

[jira] [Comment Edited] (FLINK-36167) testSinkDisorderChangeLog failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-36167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913945#comment-17913945 ] Shuai Xu edited comment on FLINK-36167 at 1/17/25 3:57 AM: --- I

[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

  1   2   3   4   5   6   7   8   9   10   >