[jira] [Updated] (FLINK-26409) Remove meaningless Kafka connector test case KafkaConsumerTestBase.runBrokerFailureTest

[ https://issues.apache.org/jira/browse/FLINK-26409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-26409: Fix Version/s: kafka-3.0.3 (was: kafka-3.0.2) > Remove

[jira] [Updated] (FLINK-30400) Stop bundling connector-base in externalized connectors

[ https://issues.apache.org/jira/browse/FLINK-30400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-30400: Fix Version/s: kafka-3.0.2 > Stop bundling connector-base in externalized

[jira] [Commented] (FLINK-30400) Stop bundling connector-base in externalized connectors

[ https://issues.apache.org/jira/browse/FLINK-30400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789514#comment-17789514 ] Tzu-Li (Gordon) Tai commented on FLINK-30400: - fixed for apache/flink-connector-kafka:v3.0

[jira] [Commented] (FLINK-33545) KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching

[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786873#comment-17786873 ] Tzu-Li (Gordon) Tai commented on FLINK-33545: -

[jira] [Commented] (FLINK-33293) Data loss with Kafka Sink

[ https://issues.apache.org/jira/browse/FLINK-33293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786872#comment-17786872 ] Tzu-Li (Gordon) Tai commented on FLINK-33293: - We have a new ticket whose description seems

[jira] [Comment Edited] (FLINK-33545) KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching

[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786863#comment-17786863 ] Tzu-Li (Gordon) Tai edited comment on FLINK-33545 at 11/16/23 5:12 PM:

[jira] [Commented] (FLINK-33545) KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching

[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786863#comment-17786863 ] Tzu-Li (Gordon) Tai commented on FLINK-33545: - {code} In a scenario that: * KafkaSource

[jira] [Commented] (FLINK-33545) KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching

[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786860#comment-17786860 ] Tzu-Li (Gordon) Tai commented on FLINK-33545: - hey [~aeolus811tw], thanks for the detailed

[jira] [Assigned] (FLINK-33545) KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching

[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-33545: --- Assignee: Tzu-Li (Gordon) Tai > KafkaSink implementation can cause

[jira] [Assigned] (FLINK-33545) KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching

[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-33545: --- Assignee: Kevin Tseng (was: Tzu-Li (Gordon) Tai) > KafkaSink

[jira] [Commented] (FLINK-33497) Update the Kafka connector to support DISTRIBUTED BY clause

[ https://issues.apache.org/jira/browse/FLINK-33497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784479#comment-17784479 ] Tzu-Li (Gordon) Tai commented on FLINK-33497: - [~twalthr] makes sense to integrate the Kafka

[jira] [Assigned] (FLINK-33497) Update the Kafka connector to support DISTRIBUTED BY clause

[ https://issues.apache.org/jira/browse/FLINK-33497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-33497: --- Assignee: Tzu-Li (Gordon) Tai > Update the Kafka connector to support

[jira] [Updated] (FLINK-26409) Remove meaningless Kafka connector test case KafkaConsumerTestBase.runBrokerFailureTest

[ https://issues.apache.org/jira/browse/FLINK-26409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-26409: Fix Version/s: kafka-3.0.2 (was: kafka-3.0.1) > Remove

[jira] [Updated] (FLINK-28303) Kafka SQL Connector loses data when restoring from a savepoint with a topic with empty partitions

[ https://issues.apache.org/jira/browse/FLINK-28303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-28303: Affects Version/s: 1.17.1 1.16.2

[jira] [Closed] (FLINK-28303) Kafka SQL Connector loses data when restoring from a savepoint with a topic with empty partitions

[ https://issues.apache.org/jira/browse/FLINK-28303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-28303. --- Resolution: Fixed > Kafka SQL Connector loses data when restoring from a savepoint

[jira] [Commented] (FLINK-28303) Kafka SQL Connector loses data when restoring from a savepoint with a topic with empty partitions

[ https://issues.apache.org/jira/browse/FLINK-28303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17778783#comment-17778783 ] Tzu-Li (Gordon) Tai commented on FLINK-28303: - Merged. apache/flink-connector-kafka:main -

[jira] [Updated] (FLINK-26409) Remove meaningless Kafka connector test case KafkaConsumerTestBase.runBrokerFailureTest

[ https://issues.apache.org/jira/browse/FLINK-26409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-26409: Affects Version/s: kafka-3.0.0 > Remove meaningless Kafka connector test case >

[jira] [Updated] (FLINK-26409) Remove meaningless Kafka connector test case KafkaConsumerTestBase.runBrokerFailureTest

[ https://issues.apache.org/jira/browse/FLINK-26409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-26409: Fix Version/s: kafka-3.0.1 kafka-3.1.0 > Remove meaningless

[jira] [Commented] (FLINK-26409) Remove meaningless Kafka connector test case KafkaConsumerTestBase.runBrokerFailureTest

[ https://issues.apache.org/jira/browse/FLINK-26409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17776482#comment-17776482 ] Tzu-Li (Gordon) Tai commented on FLINK-26409: - Perhaps the only value that test gives us is

[jira] [Assigned] (FLINK-26409) Remove meaningless Kafka connector test case KafkaConsumerTestBase.runBrokerFailureTest

[ https://issues.apache.org/jira/browse/FLINK-26409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-26409: --- Assignee: Tzu-Li (Gordon) Tai > Remove meaningless Kafka connector test

[jira] [Assigned] (FLINK-26409) Remove meaningless Kafka connector test case KafkaConsumerTestBase.runBrokerFailureTest

[ https://issues.apache.org/jira/browse/FLINK-26409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-26409: --- Assignee: (was: Tzu-Li (Gordon) Tai) > Remove meaningless Kafka

[jira] [Commented] (FLINK-26409) Remove meaningless Kafka connector test case KafkaConsumerTestBase.runBrokerFailureTest

[ https://issues.apache.org/jira/browse/FLINK-26409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17776480#comment-17776480 ] Tzu-Li (Gordon) Tai commented on FLINK-26409: - This test has indeed historically been quite

[jira] [Assigned] (FLINK-26409) Remove meaningless Kafka connector test case KafkaConsumerTestBase.runBrokerFailureTest

[ https://issues.apache.org/jira/browse/FLINK-26409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-26409: --- Assignee: Tzu-Li (Gordon) Tai > Remove meaningless Kafka connector test

[jira] [Comment Edited] (FLINK-33293) Data loss with Kafka Sink

[ https://issues.apache.org/jira/browse/FLINK-33293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17776361#comment-17776361 ] Tzu-Li (Gordon) Tai edited comment on FLINK-33293 at 10/17/23 7:30 PM:

[jira] [Comment Edited] (FLINK-33293) Data loss with Kafka Sink

[ https://issues.apache.org/jira/browse/FLINK-33293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17776361#comment-17776361 ] Tzu-Li (Gordon) Tai edited comment on FLINK-33293 at 10/17/23 7:29 PM:

[jira] [Commented] (FLINK-33293) Data loss with Kafka Sink

[ https://issues.apache.org/jira/browse/FLINK-33293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17776361#comment-17776361 ] Tzu-Li (Gordon) Tai commented on FLINK-33293: - [~jredzepovic] was this actually reproduced

[jira] [Commented] (FLINK-33191) Kafka Connector should directly depend on 3rd-party libs instead of flink-shaded repo

[ https://issues.apache.org/jira/browse/FLINK-33191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17774126#comment-17774126 ] Tzu-Li (Gordon) Tai commented on FLINK-33191: - main bd260f14dd280f464e5dcea76b3735782312b4ae

[jira] [Closed] (FLINK-33191) Kafka Connector should directly depend on 3rd-party libs instead of flink-shaded repo

[ https://issues.apache.org/jira/browse/FLINK-33191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-33191. --- Resolution: Fixed > Kafka Connector should directly depend on 3rd-party libs

[jira] [Assigned] (FLINK-33231) Memory leak in KafkaSourceReader if no data in consumed topic

[ https://issues.apache.org/jira/browse/FLINK-33231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-33231: --- Assignee: Tzu-Li (Gordon) Tai > Memory leak in KafkaSourceReader if no

[jira] [Updated] (FLINK-33191) Kafka Connector should directly depend on 3rd-party libs instead of flink-shaded repo

[ https://issues.apache.org/jira/browse/FLINK-33191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-33191: Affects Version/s: kafka-3.0.0 (was: 1.18.0) > Kafka

[jira] [Updated] (FLINK-33191) Kafka Connector should directly depend on 3rd-party libs instead of flink-shaded repo

[ https://issues.apache.org/jira/browse/FLINK-33191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-33191: Fix Version/s: kafka-3.0.1 kafka-3.1.0 > Kafka Connector

[jira] [Commented] (FLINK-33231) Memory leak in KafkaSourceReader if no data in consumed topic

[ https://issues.apache.org/jira/browse/FLINK-33231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773790#comment-17773790 ] Tzu-Li (Gordon) Tai commented on FLINK-33231: - [~lauri.suurvali] I think that would work,

[jira] [Commented] (FLINK-33231) Memory leak in KafkaSourceReader if no data in consumed topic

[ https://issues.apache.org/jira/browse/FLINK-33231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773739#comment-17773739 ] Tzu-Li (Gordon) Tai commented on FLINK-33231: - Making this a blocker for the upcoming Kafka

[jira] [Updated] (FLINK-33231) Memory leak in KafkaSourceReader if no data in consumed topic

[ https://issues.apache.org/jira/browse/FLINK-33231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-33231: Fix Version/s: kafka-3.0.1 kafka-3.1.0 > Memory leak in

[jira] [Updated] (FLINK-33231) Memory leak in KafkaSourceReader if no data in consumed topic

[ https://issues.apache.org/jira/browse/FLINK-33231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-33231: Priority: Blocker (was: Major) > Memory leak in KafkaSourceReader if no data in

[jira] [Commented] (FLINK-33231) Memory leak in KafkaSourceReader if no data in consumed topic

[ https://issues.apache.org/jira/browse/FLINK-33231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773738#comment-17773738 ] Tzu-Li (Gordon) Tai commented on FLINK-33231: - [~lauri.suurvali] great debugging! I think

[jira] [Commented] (FLINK-33104) Nightly run for Flink Kafka connector fails due to architecture tests failing

[ https://issues.apache.org/jira/browse/FLINK-33104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17772385#comment-17772385 ] Tzu-Li (Gordon) Tai commented on FLINK-33104: - [~echauchot] this seems to be the conclusion,

[jira] [Comment Edited] (FLINK-33104) Nightly run for Flink Kafka connector fails due to architecture tests failing

[ https://issues.apache.org/jira/browse/FLINK-33104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17772385#comment-17772385 ] Tzu-Li (Gordon) Tai edited comment on FLINK-33104 at 10/5/23 9:10 PM:

[jira] [Commented] (FLINK-28303) Kafka SQL Connector loses data when restoring from a savepoint with a topic with empty partitions

[ https://issues.apache.org/jira/browse/FLINK-28303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17772065#comment-17772065 ] Tzu-Li (Gordon) Tai commented on FLINK-28303: - Making this a blocker as it's confirmed to be

[jira] [Assigned] (FLINK-28303) Kafka SQL Connector loses data when restoring from a savepoint with a topic with empty partitions

[ https://issues.apache.org/jira/browse/FLINK-28303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-28303: --- Assignee: tanjialiang > Kafka SQL Connector loses data when restoring from

[jira] [Updated] (FLINK-28303) Kafka SQL Connector loses data when restoring from a savepoint with a topic with empty partitions

[ https://issues.apache.org/jira/browse/FLINK-28303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-28303: Priority: Blocker (was: Major) > Kafka SQL Connector loses data when restoring

[jira] [Updated] (FLINK-28303) Kafka SQL Connector loses data when restoring from a savepoint with a topic with empty partitions

[ https://issues.apache.org/jira/browse/FLINK-28303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-28303: Fix Version/s: kafka-3.0.1 kafka-3.1.0 > Kafka SQL Connector

[jira] [Closed] (FLINK-29398) Utilize Rack Awareness in Flink Consumer

[ https://issues.apache.org/jira/browse/FLINK-29398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-29398. --- Resolution: Fixed > Utilize Rack Awareness in Flink Consumer >

[jira] [Updated] (FLINK-29398) Utilize Rack Awareness in Flink Consumer

[ https://issues.apache.org/jira/browse/FLINK-29398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-29398: Fix Version/s: kafka-3.1.0 > Utilize Rack Awareness in Flink Consumer >

[jira] [Commented] (FLINK-29398) Utilize Rack Awareness in Flink Consumer

[ https://issues.apache.org/jira/browse/FLINK-29398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17770582#comment-17770582 ] Tzu-Li (Gordon) Tai commented on FLINK-29398: - Thanks for driving this to the finish line

[jira] [Commented] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

[ https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17770492#comment-17770492 ] Tzu-Li (Gordon) Tai commented on FLINK-30238: - [~martijnvisser] I've replied to your

[jira] [Assigned] (FLINK-32417) DynamicKafkaSource User Documentation

[ https://issues.apache.org/jira/browse/FLINK-32417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-32417: --- Assignee: Mason Chen > DynamicKafkaSource User Documentation >

[jira] [Assigned] (FLINK-32416) Initial DynamicKafkaSource Implementation

[ https://issues.apache.org/jira/browse/FLINK-32416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-32416: --- Assignee: Mason Chen > Initial DynamicKafkaSource Implementation >

[jira] [Updated] (FLINK-28758) FlinkKafkaConsumer fails to stop with savepoint

[ https://issues.apache.org/jira/browse/FLINK-28758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-28758: Fix Version/s: kafka-3.0.1 kafka-3.1.0 > FlinkKafkaConsumer

[jira] [Comment Edited] (FLINK-33017) Nightly run for Flink Kafka connector fails

[ https://issues.apache.org/jira/browse/FLINK-33017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17764321#comment-17764321 ] Tzu-Li (Gordon) Tai edited comment on FLINK-33017 at 9/12/23 5:55 PM:

[jira] [Comment Edited] (FLINK-33017) Nightly run for Flink Kafka connector fails

[ https://issues.apache.org/jira/browse/FLINK-33017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17764321#comment-17764321 ] Tzu-Li (Gordon) Tai edited comment on FLINK-33017 at 9/12/23 5:55 PM:

[jira] [Commented] (FLINK-33017) Nightly run for Flink Kafka connector fails

[ https://issues.apache.org/jira/browse/FLINK-33017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17764321#comment-17764321 ] Tzu-Li (Gordon) Tai commented on FLINK-33017: - Lets only resolve this ticket once we have a

[jira] [Commented] (FLINK-33017) Nightly run for Flink Kafka connector fails

[ https://issues.apache.org/jira/browse/FLINK-33017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17764320#comment-17764320 ] Tzu-Li (Gordon) Tai commented on FLINK-33017: - Fixed via: apache/flink-connector-kafka:main

[jira] [Updated] (FLINK-33017) Nightly run for Flink Kafka connector fails

[ https://issues.apache.org/jira/browse/FLINK-33017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-33017: Fix Version/s: kafka-3.0.1 kafka-3.1.0 > Nightly run for Flink

[jira] [Assigned] (FLINK-33017) Nightly run for Flink Kafka connector fails

[ https://issues.apache.org/jira/browse/FLINK-33017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-33017: --- Assignee: Alex Sorokoumov > Nightly run for Flink Kafka connector fails >

[jira] [Comment Edited] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

[ https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761051#comment-17761051 ] Tzu-Li (Gordon) Tai edited comment on FLINK-30238 at 8/31/23 5:40 PM:

[jira] [Comment Edited] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

[ https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761051#comment-17761051 ] Tzu-Li (Gordon) Tai edited comment on FLINK-30238 at 8/31/23 5:39 PM:

[jira] [Commented] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

[ https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761051#comment-17761051 ] Tzu-Li (Gordon) Tai commented on FLINK-30238: - hi all, I'd like to move this ticket forward

[jira] [Closed] (FLINK-31408) Add EXACTLY_ONCE support to upsert-kafka

[ https://issues.apache.org/jira/browse/FLINK-31408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-31408. --- Resolution: Fixed > Add EXACTLY_ONCE support to upsert-kafka >

[jira] [Updated] (FLINK-31408) Add EXACTLY_ONCE support to upsert-kafka

[ https://issues.apache.org/jira/browse/FLINK-31408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-31408: Fix Version/s: kafka-3.1.0 > Add EXACTLY_ONCE support to upsert-kafka >

[jira] [Commented] (FLINK-31408) Add EXACTLY_ONCE support to upsert-kafka

[ https://issues.apache.org/jira/browse/FLINK-31408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742414#comment-17742414 ] Tzu-Li (Gordon) Tai commented on FLINK-31408: - Merged to flink-connector-kafka via: main -

[jira] [Updated] (FLINK-32453) flink-connector-kafka does not build against Flink 1.18-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-32453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-32453: Affects Version/s: kafka-3.0.0 (was: 1.18.0) >

[jira] [Closed] (FLINK-32455) Breaking change in TypeSerializerUpgradeTestBase prevents flink-connector-kafka from building against 1.18-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-32455. --- Resolution: Fixed > Breaking change in TypeSerializerUpgradeTestBase prevents >

[jira] [Closed] (FLINK-32453) flink-connector-kafka does not build against Flink 1.18-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-32453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-32453. --- Resolution: Fixed > flink-connector-kafka does not build against Flink

[jira] [Updated] (FLINK-32453) flink-connector-kafka does not build against Flink 1.18-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-32453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-32453: Fix Version/s: kafka-3.0.1 kafka-3.1.0

[jira] [Updated] (FLINK-32455) Breaking change in TypeSerializerUpgradeTestBase prevents flink-connector-kafka from building against 1.18-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-32455: Fix Version/s: kafka-3.0.1 kafka-3.1.0 > Breaking change in

[jira] [Updated] (FLINK-32455) Breaking change in TypeSerializerUpgradeTestBase prevents flink-connector-kafka from building against 1.18-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-32455: Affects Version/s: kafka-3.0.0 (was: 1.18.0) >

[jira] [Commented] (FLINK-32455) Breaking change in TypeSerializerUpgradeTestBase prevents flink-connector-kafka from building against 1.18-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742413#comment-17742413 ] Tzu-Li (Gordon) Tai commented on FLINK-32455: - Merged to flink-connector-kafka via: main -

[jira] [Updated] (FLINK-32455) Breaking change in TypeSerializerUpgradeTestBase prevents flink-connector-kafka from building against 1.18-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-32455: Fix Version/s: (was: 1.18.0) > Breaking change in

[jira] [Commented] (FLINK-32455) Breaking change in TypeSerializerUpgradeTestBase prevents flink-connector-kafka from building against 1.18-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17741999#comment-17741999 ] Tzu-Li (Gordon) Tai commented on FLINK-32455: - [~renqs] I'm merging my hotfix PR now which

[jira] [Commented] (FLINK-32455) Breaking change in TypeSerializerUpgradeTestBase prevents flink-connector-kafka from building against 1.18-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17741997#comment-17741997 ] Tzu-Li (Gordon) Tai commented on FLINK-32455: - [~gaoyunhaii] that plan sounds good to me.

[jira] [Commented] (FLINK-32455) Breaking change in TypeSerializerUpgradeTestBase prevents flink-connector-kafka from building against 1.18-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17739797#comment-17739797 ] Tzu-Li (Gordon) Tai commented on FLINK-32455: - FYI preview PR for the fast workaround fix:

[jira] [Closed] (FLINK-32462) Kafka shouldn't rely on Flink-Shaded

[ https://issues.apache.org/jira/browse/FLINK-32462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-32462. --- Resolution: Fixed > Kafka shouldn't rely on Flink-Shaded >

[jira] [Updated] (FLINK-32462) Kafka shouldn't rely on Flink-Shaded

[ https://issues.apache.org/jira/browse/FLINK-32462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-32462: Fix Version/s: kafka-3.0.1 kafka-3.1.0 > Kafka shouldn't rely

[jira] [Assigned] (FLINK-32462) Kafka shouldn't rely on Flink-Shaded

[ https://issues.apache.org/jira/browse/FLINK-32462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-32462: --- Assignee: Martijn Visser > Kafka shouldn't rely on Flink-Shaded >

[jira] [Commented] (FLINK-32462) Kafka shouldn't rely on Flink-Shaded

[ https://issues.apache.org/jira/browse/FLINK-32462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17739795#comment-17739795 ] Tzu-Li (Gordon) Tai commented on FLINK-32462: - Merged to

[jira] [Comment Edited] (FLINK-32455) Breaking change in TypeSerializerUpgradeTestBase prevents flink-connector-kafka from building against 1.18-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17739787#comment-17739787 ] Tzu-Li (Gordon) Tai edited comment on FLINK-32455 at 7/4/23 4:36 AM: -

[jira] [Commented] (FLINK-32455) Breaking change in TypeSerializerUpgradeTestBase prevents flink-connector-kafka from building against 1.18-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17739787#comment-17739787 ] Tzu-Li (Gordon) Tai commented on FLINK-32455: - One (quick) fix for now might be to make a

[jira] [Comment Edited] (FLINK-32455) Breaking change in TypeSerializerUpgradeTestBase prevents flink-connector-kafka from building against 1.18-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17739785#comment-17739785 ] Tzu-Li (Gordon) Tai edited comment on FLINK-32455 at 7/4/23 4:14 AM: -

[jira] [Comment Edited] (FLINK-32455) Breaking change in TypeSerializerUpgradeTestBase prevents flink-connector-kafka from building against 1.18-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17739785#comment-17739785 ] Tzu-Li (Gordon) Tai edited comment on FLINK-32455 at 7/4/23 4:13 AM: -

[jira] [Commented] (FLINK-32455) Breaking change in TypeSerializerUpgradeTestBase prevents flink-connector-kafka from building against 1.18-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17739785#comment-17739785 ] Tzu-Li (Gordon) Tai commented on FLINK-32455: - [~gaoyunhaii] sorry for the slow reply - just

[jira] [Commented] (FLINK-32455) Breaking change in TypeSerializerUpgradeTestBase prevents flink-connector-kafka from building against 1.18-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17737935#comment-17737935 ] Tzu-Li (Gordon) Tai commented on FLINK-32455: - cc [~gaoyunhaii]  > Breaking change in

[jira] [Created] (FLINK-32455) Breaking change in TypeSerializerUpgradeTestBase prevents flink-connector-kafka from building against 1.18-SNAPSHOT

Tzu-Li (Gordon) Tai created FLINK-32455: --- Summary: Breaking change in TypeSerializerUpgradeTestBase prevents flink-connector-kafka from building against 1.18-SNAPSHOT Key: FLINK-32455 URL:

[jira] [Commented] (FLINK-32453) flink-connector-kafka does not build against Flink 1.18-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-32453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17737933#comment-17737933 ] Tzu-Li (Gordon) Tai commented on FLINK-32453: - cc 1.18.0 release managers [~knaufk]

[jira] [Updated] (FLINK-31731) No suitable constructor found for DebeziumAvroSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-31731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-31731: Parent: FLINK-32453 Issue Type: Sub-task (was: Bug) > No suitable

[jira] [Created] (FLINK-32453) flink-connector-kafka does not build against Flink 1.18-SNAPSHOT

Tzu-Li (Gordon) Tai created FLINK-32453: --- Summary: flink-connector-kafka does not build against Flink 1.18-SNAPSHOT Key: FLINK-32453 URL: https://issues.apache.org/jira/browse/FLINK-32453

[jira] [Commented] (FLINK-30859) Remove flink-connector-kafka from master branch

[ https://issues.apache.org/jira/browse/FLINK-30859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17737472#comment-17737472 ] Tzu-Li (Gordon) Tai commented on FLINK-30859: - Merged via

[jira] [Closed] (FLINK-30859) Remove flink-connector-kafka from master branch

[ https://issues.apache.org/jira/browse/FLINK-30859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-30859. --- Fix Version/s: 1.18.0 Resolution: Fixed > Remove flink-connector-kafka from

[jira] [Closed] (FLINK-31731) No suitable constructor found for DebeziumAvroSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-31731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-31731. --- Fix Version/s: 1.18.0 Resolution: Fixed > No suitable constructor found for

[jira] [Commented] (FLINK-31731) No suitable constructor found for DebeziumAvroSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-31731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17736016#comment-17736016 ] Tzu-Li (Gordon) Tai commented on FLINK-31731: - Merged for apache/flink via

[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=17727590#comment-17727590 ] Tzu-Li (Gordon) Tai commented on FLINK-31762: - Thanks for opening the ticket [~liam8]. I

[jira] [Comment Edited] (FLINK-32038) OffsetCommitMode.Kafka_periodic with checkpointing enabled

[ https://issues.apache.org/jira/browse/FLINK-32038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17727581#comment-17727581 ] Tzu-Li (Gordon) Tai edited comment on FLINK-32038 at 5/30/23 3:26 PM:

[jira] [Commented] (FLINK-32038) OffsetCommitMode.Kafka_periodic with checkpointing enabled

[ https://issues.apache.org/jira/browse/FLINK-32038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17727581#comment-17727581 ] Tzu-Li (Gordon) Tai commented on FLINK-32038: - Hi [~pritam.agarwala], it does look like that

[jira] [Comment Edited] (FLINK-32196) kafka sink under EO sometimes is unable to recover from a checkpoint

[ https://issues.apache.org/jira/browse/FLINK-32196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17726426#comment-17726426 ] Tzu-Li (Gordon) Tai edited comment on FLINK-32196 at 5/26/23 12:06 AM:

[jira] [Commented] (FLINK-32196) kafka sink under EO sometimes is unable to recover from a checkpoint

[ https://issues.apache.org/jira/browse/FLINK-32196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17726426#comment-17726426 ] Tzu-Li (Gordon) Tai commented on FLINK-32196: - [~sharonxr55] a few things to clarify first:

[jira] [Commented] (FLINK-32196) KafkaWriter recovery doesn't abort lingering transactions under the EO semantic

[ https://issues.apache.org/jira/browse/FLINK-32196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17726390#comment-17726390 ] Tzu-Li (Gordon) Tai commented on FLINK-32196: - In terms of the lingering transactions you

[jira] [Comment Edited] (FLINK-32196) KafkaWriter recovery doesn't abort lingering transactions under the EO semantic

[ https://issues.apache.org/jira/browse/FLINK-32196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17726385#comment-17726385 ] Tzu-Li (Gordon) Tai edited comment on FLINK-32196 at 5/25/23 8:56 PM:

[jira] [Commented] (FLINK-32196) KafkaWriter recovery doesn't abort lingering transactions under the EO semantic

[ https://issues.apache.org/jira/browse/FLINK-32196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17726385#comment-17726385 ] Tzu-Li (Gordon) Tai commented on FLINK-32196: - Hi [~sharonxr55], the

[jira] [Updated] (FLINK-31632) watermark aligned idle source can't resume

[ https://issues.apache.org/jira/browse/FLINK-31632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-31632: Fix Version/s: 1.16.2 1.18.0 1.17.1 >

[jira] [Closed] (FLINK-31632) watermark aligned idle source can't resume

[ https://issues.apache.org/jira/browse/FLINK-31632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-31632. --- Resolution: Fixed > watermark aligned idle source can't resume >

  1   2   3   4   5   6   7   8   9   10   >