[jira] [Commented] (FLINK-35093) Postgres source connector support SPECIFIC_OFFSETS start up mode from an existed replication slot.

[ https://issues.apache.org/jira/browse/FLINK-35093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17914413#comment-17914413 ] Hongshun Wang commented on FLINK-35093: --- [~phamvinh1712] it's also a good choice.

[jira] [Comment Edited] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908757#comment-17908757 ] Hongshun Wang edited comment on FLINK-31762 at 12/30/24 2:42 AM: -

[jira] [Comment Edited] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908757#comment-17908757 ] Hongshun Wang edited comment on FLINK-31762 at 12/30/24 2:39 AM: -

[jira] [Comment Edited] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908757#comment-17908757 ] Hongshun Wang edited comment on FLINK-31762 at 12/30/24 2:39 AM: -

[jira] [Comment Edited] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908757#comment-17908757 ] Hongshun Wang edited comment on FLINK-31762 at 12/30/24 2:34 AM: -

[jira] [Comment Edited] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908757#comment-17908757 ] Hongshun Wang edited comment on FLINK-31762 at 12/30/24 2:32 AM: -

[jira] [Comment Edited] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908757#comment-17908757 ] Hongshun Wang edited comment on FLINK-31762 at 12/30/24 2:32 AM: -

[jira] [Comment Edited] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908757#comment-17908757 ] Hongshun Wang edited comment on FLINK-31762 at 12/30/24 2:25 AM: -

[jira] [Comment Edited] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908757#comment-17908757 ] Hongshun Wang edited comment on FLINK-31762 at 12/30/24 2:24 AM: -

[jira] [Comment Edited] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908757#comment-17908757 ] Hongshun Wang edited comment on FLINK-31762 at 12/30/24 2:23 AM: -

[jira] [Comment Edited] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908757#comment-17908757 ] Hongshun Wang edited comment on FLINK-31762 at 12/30/24 2:22 AM: -

[jira] [Commented] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908757#comment-17908757 ] Hongshun Wang commented on FLINK-31762: --- Hi, [~lorenzo.affetti]  I'd like to do it

[jira] [Comment Edited] (FLINK-36914) Sources with watermark alignment should wait for watermark generation

[ https://issues.apache.org/jira/browse/FLINK-36914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906722#comment-17906722 ] Hongshun Wang edited comment on FLINK-36914 at 12/18/24 11:47 AM:

[jira] [Comment Edited] (FLINK-36914) Sources with watermark alignment should wait for watermark generation

[ https://issues.apache.org/jira/browse/FLINK-36914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906722#comment-17906722 ] Hongshun Wang edited comment on FLINK-36914 at 12/18/24 11:45 AM:

[jira] [Comment Edited] (FLINK-36914) Sources with watermark alignment should wait for watermark generation

[ https://issues.apache.org/jira/browse/FLINK-36914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906722#comment-17906722 ] Hongshun Wang edited comment on FLINK-36914 at 12/18/24 11:40 AM:

[jira] [Comment Edited] (FLINK-36914) Sources with watermark alignment should wait for watermark generation

[ https://issues.apache.org/jira/browse/FLINK-36914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906722#comment-17906722 ] Hongshun Wang edited comment on FLINK-36914 at 12/18/24 11:40 AM:

[jira] [Commented] (FLINK-36914) Sources with watermark alignment should wait for watermark generation

[ https://issues.apache.org/jira/browse/FLINK-36914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906722#comment-17906722 ] Hongshun Wang commented on FLINK-36914: --- Hi, [~xccui] , I have also met same probl

[jira] [Comment Edited] (FLINK-36914) Sources with watermark alignment should wait for watermark generation

[ https://issues.apache.org/jira/browse/FLINK-36914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906722#comment-17906722 ] Hongshun Wang edited comment on FLINK-36914 at 12/18/24 11:38 AM:

[jira] [Created] (FLINK-36844) Postgres CDC document add mapping from postgres timestamp_tz to flink timestamp ltz

Hongshun Wang created FLINK-36844: - Summary: Postgres CDC document add mapping from postgres timestamp_tz to flink timestamp ltz Key: FLINK-36844 URL: https://issues.apache.org/jira/browse/FLINK-36844

[jira] [Commented] (FLINK-36844) Postgres CDC document add mapping from postgres timestamp_tz to flink timestamp ltz

[ https://issues.apache.org/jira/browse/FLINK-36844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17902912#comment-17902912 ] Hongshun Wang commented on FLINK-36844: --- I'd like to do it. > Postgres CDC docume

[jira] [Commented] (FLINK-36816) Support source parallelism setting for JDBC connector

[ https://issues.apache.org/jira/browse/FLINK-36816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17902495#comment-17902495 ] Hongshun Wang commented on FLINK-36816: --- [~grzegorz.kolakowski] , thanks for your

[jira] [Commented] (FLINK-34554) Using EXACTLY_ONCE with KafkaSink cause broker's OOM due to newly created transactionalId per checkpoint

[ https://issues.apache.org/jira/browse/FLINK-34554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17902488#comment-17902488 ] Hongshun Wang commented on FLINK-34554: --- [~arvid] , It seems that  Kafka client 3.

[jira] [Commented] (FLINK-36780) Kafka source disable partition discovery unexpectedly

[ https://issues.apache.org/jira/browse/FLINK-36780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17901414#comment-17901414 ] Hongshun Wang commented on FLINK-36780: --- [~liuml07] , I agree with you. This modif

[jira] [Commented] (FLINK-35859) [flink-cdc] Fix: The assigner is not ready to offer finished split information, this should not be called

[ https://issues.apache.org/jira/browse/FLINK-35859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17900229#comment-17900229 ] Hongshun Wang commented on FLINK-35859: --- > Users cannot immediately perceive task

[jira] [Commented] (FLINK-36630) kafka-connector random WakeupException after enabling watermark alignment

[ https://issues.apache.org/jira/browse/FLINK-36630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896592#comment-17896592 ] Hongshun Wang commented on FLINK-36630: --- [~alago] Be free to make a PR. > kafka-c

[jira] [Commented] (FLINK-36630) kafka-connector random WakeupException after enabling watermark alignment

[ https://issues.apache.org/jira/browse/FLINK-36630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894431#comment-17894431 ] Hongshun Wang commented on FLINK-36630: --- [~alago] Just wrapped it is not enough, w

[jira] [Comment Edited] (FLINK-36630) kafka-connector random WakeupException after enabling watermark alignment

[ https://issues.apache.org/jira/browse/FLINK-36630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894413#comment-17894413 ] Hongshun Wang edited comment on FLINK-36630 at 10/31/24 4:08 AM: -

[jira] [Comment Edited] (FLINK-36630) kafka-connector random WakeupException after enabling watermark alignment

[ https://issues.apache.org/jira/browse/FLINK-36630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894413#comment-17894413 ] Hongshun Wang edited comment on FLINK-36630 at 10/31/24 4:09 AM: -

[jira] [Comment Edited] (FLINK-36630) kafka-connector random WakeupException after enabling watermark alignment

[ https://issues.apache.org/jira/browse/FLINK-36630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894413#comment-17894413 ] Hongshun Wang edited comment on FLINK-36630 at 10/31/24 4:03 AM: -

[jira] [Commented] (FLINK-36630) kafka-connector random WakeupException after enabling watermark alignment

[ https://issues.apache.org/jira/browse/FLINK-36630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894413#comment-17894413 ] Hongshun Wang commented on FLINK-36630: --- It seems that https://issues.apache.org/j

[jira] [Commented] (FLINK-36584) PostgresIncrementalSource is not exiting the flink execution when StartupOptions is snapshot and create multiple replication slots

[ https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893683#comment-17893683 ] Hongshun Wang commented on FLINK-36584: --- [~dasarianil] , Maybe slack of flink cdc

[jira] [Commented] (FLINK-36609) Protobuf Format not support proto3

[ https://issues.apache.org/jira/browse/FLINK-36609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893680#comment-17893680 ] Hongshun Wang commented on FLINK-36609: --- I'd like to do it. > Protobuf Format not

[jira] [Created] (FLINK-36618) Improve PostgresDialect.discoverDataCollections to reduce the start time of Postgres CDC

Hongshun Wang created FLINK-36618: - Summary: Improve PostgresDialect.discoverDataCollections to reduce the start time of Postgres CDC Key: FLINK-36618 URL: https://issues.apache.org/jira/browse/FLINK-36618

[jira] [Commented] (FLINK-36584) PostgresIncrementalSource is not exiting the flink execution when StartupOptions is snapshot and create multiple replication slots

[ https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893670#comment-17893670 ] Hongshun Wang commented on FLINK-36584: --- Yes, when skip backfill, the snapshot spo

[jira] [Commented] (FLINK-36584) PostgresIncrementalSource is not exiting the flink execution when StartupOptions is snapshot and create multiple replication slots

[ https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893676#comment-17893676 ] Hongshun Wang commented on FLINK-36584: --- [~dasarianil] ,  > Is there a reason for

[jira] [Updated] (FLINK-36584) PostgresIncrementalSource is not exiting the flink execution when StartupOptions is snapshot and create multiple replication slots

[ https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongshun Wang updated FLINK-36584: -- Attachment: image-2024-10-29-10-44-23-005.png > PostgresIncrementalSource is not exiting the f

[jira] [Updated] (FLINK-36584) PostgresIncrementalSource is not exiting the flink execution when StartupOptions is snapshot and create multiple replication slots

[ https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongshun Wang updated FLINK-36584: -- Attachment: image-2024-10-29-10-00-44-321.png > PostgresIncrementalSource is not exiting the f

[jira] (FLINK-36609) Protobuf Format not support proto3

[ https://issues.apache.org/jira/browse/FLINK-36609 ] Hongshun Wang deleted comment on FLINK-36609: --- was (Author: JIRAUSER298968): I'd like to fix it, getDescriptor should return GenericDescriptor rather than Descriptor > Protobuf Format not

[jira] [Created] (FLINK-36609) Protobuf Format not support proto3

Hongshun Wang created FLINK-36609: - Summary: Protobuf Format not support proto3 Key: FLINK-36609 URL: https://issues.apache.org/jira/browse/FLINK-36609 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-36609) Protobuf Format not support proto3

[ https://issues.apache.org/jira/browse/FLINK-36609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893345#comment-17893345 ] Hongshun Wang commented on FLINK-36609: --- I'd like to fix it, getDescriptor should

[jira] [Commented] (FLINK-36584) PostgresIncrementalSource is not exiting the flink execution when StartupOptions is snapshot and create multiple replication slots

[ https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893043#comment-17893043 ] Hongshun Wang commented on FLINK-36584: --- [~dasarianil] , the design is like [http

[jira] [Commented] (FLINK-36584) PostgresIncrementalSource is not exiting the flink execution when StartupOptions is snapshot and create multiple replication slots

[ https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892678#comment-17892678 ] Hongshun Wang commented on FLINK-36584: --- # Issue-1: yes, you can see the argue of

[jira] [Commented] (FLINK-36569) flink kafka connector do not close kafka produer when it checkpoint success

[ https://issues.apache.org/jira/browse/FLINK-36569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892455#comment-17892455 ] Hongshun Wang commented on FLINK-36569: --- [~ft20082]  Thanks for your explain, it s

[jira] [Commented] (FLINK-36569) flink kafka connector do not close kafka produer when it checkpoint success

[ https://issues.apache.org/jira/browse/FLINK-36569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891222#comment-17891222 ] Hongshun Wang commented on FLINK-36569: --- You mean that kafka sink with EXACTLY-ONC

[jira] [Commented] (FLINK-35093) Postgres source connector support SPECIFIC_OFFSETS start up mode from an existed replication slot.

[ https://issues.apache.org/jira/browse/FLINK-35093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17889614#comment-17889614 ] Hongshun Wang commented on FLINK-35093: --- [~phamvinh1712] Sure, you can take it if

[jira] [Commented] (FLINK-32766) Support kafka catalog

[ https://issues.apache.org/jira/browse/FLINK-32766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885848#comment-17885848 ] Hongshun Wang commented on FLINK-32766: --- It's been a long time for this job. [~mel

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

[ https://issues.apache.org/jira/browse/FLINK-35387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878696#comment-17878696 ] Hongshun Wang commented on FLINK-35387: --- I'd like to do it. > PG CDC source suppo

[jira] [Created] (FLINK-36174) CDC yaml without pipeline will throw NullPointException

Hongshun Wang created FLINK-36174: - Summary: CDC yaml without pipeline will throw NullPointException Key: FLINK-36174 URL: https://issues.apache.org/jira/browse/FLINK-36174 Project: Flink Iss

[jira] [Created] (FLINK-36163) Kafka cdc pipeline source supports protobuf format.

Hongshun Wang created FLINK-36163: - Summary: Kafka cdc pipeline source supports protobuf format. Key: FLINK-36163 URL: https://issues.apache.org/jira/browse/FLINK-36163 Project: Flink Issue T

[jira] [Comment Edited] (FLINK-35859) [flink-cdc] Fix: The assigner is not ready to offer finished split information, this should not be called

[ https://issues.apache.org/jira/browse/FLINK-35859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876584#comment-17876584 ] Hongshun Wang edited comment on FLINK-35859 at 8/26/24 5:45 AM: --

[jira] [Comment Edited] (FLINK-35859) [flink-cdc] Fix: The assigner is not ready to offer finished split information, this should not be called

[ https://issues.apache.org/jira/browse/FLINK-35859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876584#comment-17876584 ] Hongshun Wang edited comment on FLINK-35859 at 8/26/24 5:45 AM: --

[jira] [Commented] (FLINK-35859) [flink-cdc] Fix: The assigner is not ready to offer finished split information, this should not be called

[ https://issues.apache.org/jira/browse/FLINK-35859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876584#comment-17876584 ] Hongshun Wang commented on FLINK-35859: --- [~pacinogong] the docs of AssignerStatus

[jira] [Commented] (FLINK-36150) tables.exclude is not valid if scan.binlog.newly-added-table.enabled is true.

[ https://issues.apache.org/jira/browse/FLINK-36150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876487#comment-17876487 ] Hongshun Wang commented on FLINK-36150: --- I'd like to do it. > tables.exclude is n

[jira] [Created] (FLINK-36150) tables.exclude is not valid if scan.binlog.newly-added-table.enabled is true.

Hongshun Wang created FLINK-36150: - Summary: tables.exclude is not valid if scan.binlog.newly-added-table.enabled is true. Key: FLINK-36150 URL: https://issues.apache.org/jira/browse/FLINK-36150 Proje

[jira] [Updated] (FLINK-36076) Hotfix: Set isSchemaChangeApplying as volatile for thread safe.

[ https://issues.apache.org/jira/browse/FLINK-36076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongshun Wang updated FLINK-36076: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.3.0) > Hotfix: Set isSchemaChangeA

[jira] [Updated] (FLINK-36094) CDC SchemaRegistryRequestHandler should throw exception which is not SchemaEvolveException

[ https://issues.apache.org/jira/browse/FLINK-36094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongshun Wang updated FLINK-36094: -- Priority: Blocker (was: Critical) > CDC SchemaRegistryRequestHandler should throw exception w

[jira] [Updated] (FLINK-36076) Hotfix: Set isSchemaChangeApplying as volatile for thread safe.

[ https://issues.apache.org/jira/browse/FLINK-36076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongshun Wang updated FLINK-36076: -- Affects Version/s: cdc-3.1.1 (was: cdc-3.2.0) > Hotfix: Set isSchem

[jira] [Updated] (FLINK-36076) Hotfix: Set isSchemaChangeApplying as volatile for thread safe.

[ https://issues.apache.org/jira/browse/FLINK-36076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongshun Wang updated FLINK-36076: -- Priority: Blocker (was: Major) > Hotfix: Set isSchemaChangeApplying as volatile for thread sa

[jira] [Commented] (FLINK-36094) CDC SchemaRegistryRequestHandler should throw exception which is not SchemaEvolveException

[ https://issues.apache.org/jira/browse/FLINK-36094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874836#comment-17874836 ] Hongshun Wang commented on FLINK-36094: --- I'd like to do it > CDC SchemaRegistryRe

[jira] [Created] (FLINK-36094) CDC SchemaRegistryRequestHandler should throw exception which is not SchemaEvolveException

Hongshun Wang created FLINK-36094: - Summary: CDC SchemaRegistryRequestHandler should throw exception which is not SchemaEvolveException Key: FLINK-36094 URL: https://issues.apache.org/jira/browse/FLINK-36094

[jira] [Updated] (FLINK-36076) Hotfix: Set isSchemaChangeApplying as volatile for thread safe.

[ https://issues.apache.org/jira/browse/FLINK-36076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongshun Wang updated FLINK-36076: -- Summary: Hotfix: Set isSchemaChangeApplying as volatile for thread safe. (was: Hotfix: Set is

[jira] [Commented] (FLINK-36076) Hotfix: Set isSchemaChangeApplying as isSchemaChangeApplying for thread safe.

[ https://issues.apache.org/jira/browse/FLINK-36076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874174#comment-17874174 ] Hongshun Wang commented on FLINK-36076: --- I'd like to do it. > Hotfix: Set isSchem

[jira] [Created] (FLINK-36076) Hotfix: Set isSchemaChangeApplying as isSchemaChangeApplying for thread safe.

Hongshun Wang created FLINK-36076: - Summary: Hotfix: Set isSchemaChangeApplying as isSchemaChangeApplying for thread safe. Key: FLINK-36076 URL: https://issues.apache.org/jira/browse/FLINK-36076 Proje

[jira] [Created] (FLINK-36036) CDC remove unused dependency jar from calcite-core

Hongshun Wang created FLINK-36036: - Summary: CDC remove unused dependency jar from calcite-core Key: FLINK-36036 URL: https://issues.apache.org/jira/browse/FLINK-36036 Project: Flink Issue Ty

[jira] [Updated] (FLINK-36023) Flink CDC K8S Native Application Mode add wrong jar url.

[ https://issues.apache.org/jira/browse/FLINK-36023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongshun Wang updated FLINK-36023: -- Description: In https://issues.apache.org/jira/browse/FLINK-34853 , a great job made to summi

[jira] [Commented] (FLINK-36023) Flink CDC K8S Native Application Mode add wrong jar url.

[ https://issues.apache.org/jira/browse/FLINK-36023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872264#comment-17872264 ] Hongshun Wang commented on FLINK-36023: --- I'd like to do it. > Flink CDC K8S Nativ

[jira] [Updated] (FLINK-36023) Flink CDC K8S Native Application Mode add wrong jar url.

[ https://issues.apache.org/jira/browse/FLINK-36023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongshun Wang updated FLINK-36023: -- Component/s: Flink CDC Fix Version/s: cdc-3.2.0 Affects Version/s: cdc-3.1.1

[jira] [Created] (FLINK-36023) Flink K8S Native Application Mode add wrong jar url.

Hongshun Wang created FLINK-36023: - Summary: Flink K8S Native Application Mode add wrong jar url. Key: FLINK-36023 URL: https://issues.apache.org/jira/browse/FLINK-36023 Project: Flink Issue

[jira] [Commented] (FLINK-36007) cdc load and register factory in once search

[ https://issues.apache.org/jira/browse/FLINK-36007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871928#comment-17871928 ] Hongshun Wang commented on FLINK-36007: --- I'd like to do it. > cdc load and regist

[jira] [Created] (FLINK-36007) cdc load and register factory in once search

Hongshun Wang created FLINK-36007: - Summary: cdc load and register factory in once search Key: FLINK-36007 URL: https://issues.apache.org/jira/browse/FLINK-36007 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-35994) CDC pipeline use SavepointRestoreSettings in flink config flile as a fallback strategy.

Hongshun Wang created FLINK-35994: - Summary: CDC pipeline use SavepointRestoreSettings in flink config flile as a fallback strategy. Key: FLINK-35994 URL: https://issues.apache.org/jira/browse/FLINK-35994

[jira] [Commented] (FLINK-35968) Remove flink-cdc-runtime depedency from connectors

[ https://issues.apache.org/jira/browse/FLINK-35968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870453#comment-17870453 ] Hongshun Wang commented on FLINK-35968: --- [~Leonard] , [~ruanhang1993] , [~jiabaosu

[jira] [Created] (FLINK-35968) Remove flink-cdc-runtime depedency from connectors

Hongshun Wang created FLINK-35968: - Summary: Remove flink-cdc-runtime depedency from connectors Key: FLINK-35968 URL: https://issues.apache.org/jira/browse/FLINK-35968 Project: Flink Issue Ty

[jira] [Commented] (FLINK-35861) The dependency of kafka sql connector seems wrong

[ https://issues.apache.org/jira/browse/FLINK-35861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867148#comment-17867148 ] Hongshun Wang commented on FLINK-35861: --- [~martijnvisser] ,[~xuyangzhong]  Maybe w

[jira] [Commented] (FLINK-35859) [flink-cdc] Fix: The assigner is not ready to offer finished split information, this should not be called

[ https://issues.apache.org/jira/browse/FLINK-35859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866677#comment-17866677 ] Hongshun Wang commented on FLINK-35859: --- I'd like to do it. > [flink-cdc] Fix: Th

[jira] [Created] (FLINK-35859) [flink-cdc] Fix: The assigner is not ready to offer finished split information, this should not be called

Hongshun Wang created FLINK-35859: - Summary: [flink-cdc] Fix: The assigner is not ready to offer finished split information, this should not be called Key: FLINK-35859 URL: https://issues.apache.org/jira/browse/FL

[jira] [Updated] (FLINK-35849) [flink-cdc] Use expose_snapshot to read snapshot splits of postgres cdc connector.

[ https://issues.apache.org/jira/browse/FLINK-35849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongshun Wang updated FLINK-35849: -- Description: In current postgres cdc connector, we use incremental framework to read data[1],

[jira] [Updated] (FLINK-35849) [flink-cdc] Use expose_snapshot to read snapshot splits of postgres cdc connector.

[ https://issues.apache.org/jira/browse/FLINK-35849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongshun Wang updated FLINK-35849: -- Summary: [flink-cdc] Use expose_snapshot to read snapshot splits of postgres cdc connector. (

[jira] [Commented] (FLINK-35849) [flink-cdc] Use expose_snapshot to read snapshot of postgres cdc connector.

[ https://issues.apache.org/jira/browse/FLINK-35849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866050#comment-17866050 ] Hongshun Wang commented on FLINK-35849: --- I'd like to do it. Please assign this for

[jira] [Created] (FLINK-35849) [flink-cdc] Use expose_snapshot to read snapshot of postgres cdc connector.

Hongshun Wang created FLINK-35849: - Summary: [flink-cdc] Use expose_snapshot to read snapshot of postgres cdc connector. Key: FLINK-35849 URL: https://issues.apache.org/jira/browse/FLINK-35849 Project

[jira] [Commented] (FLINK-35760) [docs] Add scan.newly-added-table.enabled to docs.

[ https://issues.apache.org/jira/browse/FLINK-35760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863107#comment-17863107 ] Hongshun Wang commented on FLINK-35760: --- I'd like to do it. > [docs] Add scan.new

[jira] [Created] (FLINK-35760) [docs] Add scan.newly-added-table.enabled to docs.

Hongshun Wang created FLINK-35760: - Summary: [docs] Add scan.newly-added-table.enabled to docs. Key: FLINK-35760 URL: https://issues.apache.org/jira/browse/FLINK-35760 Project: Flink Issue Ty

[jira] [Commented] (FLINK-35759) [docs] Add 'scan.incremental.snapshot.backfill.skip' to docs.

[ https://issues.apache.org/jira/browse/FLINK-35759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863106#comment-17863106 ] Hongshun Wang commented on FLINK-35759: --- I'd like to do it. > [docs] Add 'scan.i

[jira] [Created] (FLINK-35759) [docs] Add 'scan.incremental.snapshot.backfill.skip' to docs.

Hongshun Wang created FLINK-35759: - Summary: [docs] Add 'scan.incremental.snapshot.backfill.skip' to docs. Key: FLINK-35759 URL: https://issues.apache.org/jira/browse/FLINK-35759 Project: Flink

[jira] [Created] (FLINK-35715) Mysql Source support schema cache to deserialize record

Hongshun Wang created FLINK-35715: - Summary: Mysql Source support schema cache to deserialize record Key: FLINK-35715 URL: https://issues.apache.org/jira/browse/FLINK-35715 Project: Flink Iss

[jira] [Commented] (FLINK-34554) Using EXACTLY_ONCE with KafkaSink cause broker's OOM due to newly created transactionalId per checkpoint

[ https://issues.apache.org/jira/browse/FLINK-34554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860058#comment-17860058 ] Hongshun Wang commented on FLINK-34554: ---  Is there any update on this Jira ticket?

[jira] [Commented] (FLINK-35693) Change variable specificOffsetFile, specificOffsetPos and startupTimestampMillis to Offset in StartupOptions

[ https://issues.apache.org/jira/browse/FLINK-35693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17859860#comment-17859860 ] Hongshun Wang commented on FLINK-35693: --- [~Leonard] , [~ruanhang1993] [~jiabaosun]

[jira] [Created] (FLINK-35693) Change variable specificOffsetFile, specificOffsetPos and startupTimestampMillis to Offset in StartupOptions

Hongshun Wang created FLINK-35693: - Summary: Change variable specificOffsetFile, specificOffsetPos and startupTimestampMillis to Offset in StartupOptions Key: FLINK-35693 URL: https://issues.apache.org/jira/browse

[jira] [Commented] (FLINK-35121) CDC pipeline connector should verify requiredOptions and optionalOptions

[ https://issues.apache.org/jira/browse/FLINK-35121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854253#comment-17854253 ] Hongshun Wang commented on FLINK-35121: --- [~kwafor] , Sorry, I have done it > CDC

[jira] [Updated] (FLINK-35567) CDC BinaryWriter cast NullableSerializerWrapper error

[ https://issues.apache.org/jira/browse/FLINK-35567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongshun Wang updated FLINK-35567: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.1) > CDC BinaryWriter cast Nulla

[jira] [Created] (FLINK-35567) CDC BinaryWriter cast NullableSerializerWrapper error

Hongshun Wang created FLINK-35567: - Summary: CDC BinaryWriter cast NullableSerializerWrapper error Key: FLINK-35567 URL: https://issues.apache.org/jira/browse/FLINK-35567 Project: Flink Issu

[jira] [Updated] (FLINK-35567) CDC BinaryWriter cast NullableSerializerWrapper error

[ https://issues.apache.org/jira/browse/FLINK-35567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongshun Wang updated FLINK-35567: -- Affects Version/s: cdc-3.1.1 (was: cdc-3.2.0) > CDC BinaryWriter ca

[jira] [Created] (FLINK-35524) Clear connections pools when reader exist.

Hongshun Wang created FLINK-35524: - Summary: Clear connections pools when reader exist. Key: FLINK-35524 URL: https://issues.apache.org/jira/browse/FLINK-35524 Project: Flink Issue Type: Bug

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17849161#comment-17849161 ] Hongshun Wang commented on FLINK-35067: --- [~walls.flink.m], I hope you’re doing wel

[jira] [Commented] (FLINK-35385) upgrader flink dependency version to 1.19

[ https://issues.apache.org/jira/browse/FLINK-35385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848438#comment-17848438 ] Hongshun Wang commented on FLINK-35385: --- We can ensure multi-version compatibility

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

Hongshun Wang created FLINK-35387: - Summary: PG CDC source support heart beat Key: FLINK-35387 URL: https://issues.apache.org/jira/browse/FLINK-35387 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35385) upgrader flink dependency version to 1.19

Hongshun Wang created FLINK-35385: - Summary: upgrader flink dependency version to 1.19 Key: FLINK-35385 URL: https://issues.apache.org/jira/browse/FLINK-35385 Project: Flink Issue Type: Impro

[jira] [Commented] (FLINK-35349) Use connection in openJdbcConnection of SqlServerDialect/Db2Dialect/OracleDialect

[ https://issues.apache.org/jira/browse/FLINK-35349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846183#comment-17846183 ] Hongshun Wang commented on FLINK-35349: --- I'd like to do it. > Use connection in o

[jira] [Created] (FLINK-35349) Use connection in openJdbcConnection of SqlServerDialect/Db2Dialect/OracleDialect

Hongshun Wang created FLINK-35349: - Summary: Use connection in openJdbcConnection of SqlServerDialect/Db2Dialect/OracleDialect Key: FLINK-35349 URL: https://issues.apache.org/jira/browse/FLINK-35349 P

[jira] [Commented] (FLINK-35344) Move same code from multiple subclasses to JdbcSourceChunkSplitter

[ https://issues.apache.org/jira/browse/FLINK-35344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846167#comment-17846167 ] Hongshun Wang commented on FLINK-35344: --- I'd like to do it. > Move same code from

  1   2   3   >