[jira] [Updated] (FLINK-35641) ParquetSchemaConverter should correctly handle field optionality

[ https://issues.apache.org/jira/browse/FLINK-35641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-35641: Labels: patch-available (was: ) > ParquetSchemaConverter should correctly handle

[jira] [Assigned] (FLINK-35641) ParquetSchemaConverter should correctly handle field optionality

[ https://issues.apache.org/jira/browse/FLINK-35641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-35641: --- Assignee: Alex Sorokoumov > ParquetSchemaConverter should correctly handle

[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 mean

[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 connecto

[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&focusedCommentId=17789514#comment-17789514 ] Tzu-Li (Gordon) Tai commented on FLINK-30400: - fixed for apache/flink-connec

[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&focusedCommentId=17786873#comment-17786873 ] Tzu-Li (Gordon) Tai commented on FLINK-33545: - https://issues.apache.org/jir

[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&focusedCommentId=17786872#comment-17786872 ] Tzu-Li (Gordon) Tai commented on FLINK-33293: - We have a new ticket whose de

[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&focusedCommentId=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&focusedCommentId=17786863#comment-17786863 ] Tzu-Li (Gordon) Tai commented on FLINK-33545: - {code} In a scenario that:

[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&focusedCommentId=17786860#comment-17786860 ] Tzu-Li (Gordon) Tai commented on FLINK-33545: - hey [~aeolus811tw], thanks fo

[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 dataloss

[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 implementatio

[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&focusedCommentId=17784479#comment-17784479 ] Tzu-Li (Gordon) Tai commented on FLINK-33497: - [~twalthr] makes sense to int

[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 DISTR

[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 mean

[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 kafk

[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 w

[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&focusedCommentId=17778783#comment-17778783 ] Tzu-Li (Gordon) Tai commented on FLINK-28303: - Merged. apache/flink-connect

[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 > K

[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 Kaf

[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&focusedCommentId=17776482#comment-17776482 ] Tzu-Li (Gordon) Tai commented on FLINK-26409: - Perhaps the only value that t

[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 cas

[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 connect

[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&focusedCommentId=17776480#comment-17776480 ] Tzu-Li (Gordon) Tai commented on FLINK-26409: - This test has indeed historic

[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 cas

[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&focusedCommentId=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&focusedCommentId=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&focusedCommentId=17776361#comment-17776361 ] Tzu-Li (Gordon) Tai commented on FLINK-33293: - [~jredzepovic] was this actua

[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&focusedCommentId=17774126#comment-17774126 ] Tzu-Li (Gordon) Tai commented on FLINK-33191: - main bd260f14dd280f464e5dcea7

[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 instead

[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 data

[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 Co

[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 should

[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&focusedCommentId=17773790#comment-17773790 ] Tzu-Li (Gordon) Tai commented on FLINK-33231: - [~lauri.suurvali] I think tha

[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&focusedCommentId=17773739#comment-17773739 ] Tzu-Li (Gordon) Tai commented on FLINK-33231: - Making this a blocker for the

[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 KafkaSo

[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 c

[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&focusedCommentId=17773738#comment-17773738 ] Tzu-Li (Gordon) Tai commented on FLINK-33231: - [~lauri.suurvali] great debug

[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&focusedCommentId=17772385#comment-17772385 ] Tzu-Li (Gordon) Tai commented on FLINK-33104: - [~echauchot] this seems to be

[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&focusedCommentId=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&focusedCommentId=17772065#comment-17772065 ] Tzu-Li (Gordon) Tai commented on FLINK-28303: - Making this a blocker as it's

[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 fr

[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 lo

[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&focusedCommentId=17770582#comment-17770582 ] Tzu-Li (Gordon) Tai commented on FLINK-29398: - Thanks for driving this to th

[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&focusedCommentId=17770492#comment-17770492 ] Tzu-Li (Gordon) Tai commented on FLINK-30238: - [~martijnvisser] I've replied

[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 fai

[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&focusedCommentId=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&focusedCommentId=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&focusedCommentId=17764321#comment-17764321 ] Tzu-Li (Gordon) Tai commented on FLINK-33017: - Lets only resolve this ticket

[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&focusedCommentId=17764320#comment-17764320 ] Tzu-Li (Gordon) Tai commented on FLINK-33017: - Fixed via: apache/flink-conne

[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&focusedCommentId=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&focusedCommentId=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&focusedCommentId=17761051#comment-17761051 ] Tzu-Li (Gordon) Tai commented on FLINK-30238: - hi all, I'd like to move this

[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&focusedCommentId=17742414#comment-17742414 ] Tzu-Li (Gordon) Tai commented on FLINK-31408: - Merged to flink-connector-kaf

[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) > flink-co

[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 > fli

[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 1.18-SNAPSHOT

[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 (w

[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 Typ

[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) > Breaking

[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&focusedCommentId=17742413#comment-17742413 ] Tzu-Li (Gordon) Tai commented on FLINK-32455: - Merged to flink-connector-kaf

[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 TypeSerializerUpgradeTestBas

[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&focusedCommentId=17741999#comment-17741999 ] Tzu-Li (Gordon) Tai commented on FLINK-32455: - [~renqs] I'm merging my hotfi

[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&focusedCommentId=17741997#comment-17741997 ] Tzu-Li (Gordon) Tai commented on FLINK-32455: - [~gaoyunhaii] that plan sound

[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&focusedCommentId=17739797#comment-17739797 ] Tzu-Li (Gordon) Tai commented on FLINK-32455: - FYI preview PR for the fast w

[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 o

[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&focusedCommentId=17739795#comment-17739795 ] Tzu-Li (Gordon) Tai commented on FLINK-32462: - Merged to {{{}apache/flink-co

[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&focusedCommentId=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&focusedCommentId=17739787#comment-17739787 ] Tzu-Li (Gordon) Tai commented on FLINK-32455: - One (quick) fix for now might

[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&focusedCommentId=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&focusedCommentId=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&focusedCommentId=17739785#comment-17739785 ] Tzu-Li (Gordon) Tai commented on FLINK-32455: - [~gaoyunhaii] sorry for the s

[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&focusedCommentId=17737935#comment-17737935 ] Tzu-Li (Gordon) Tai commented on FLINK-32455: - cc [~gaoyunhaii]  > Breaking

[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: https://issues.apa

[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&focusedCommentId=17737933#comment-17737933 ] Tzu-Li (Gordon) Tai commented on FLINK-32453: - cc 1.18.0 release managers [~

[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 constru

[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 Projec

[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&focusedCommentId=17737472#comment-17737472 ] Tzu-Li (Gordon) Tai commented on FLINK-30859: - Merged via apache/flink:149a5

[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 m

[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 D

[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&focusedCommentId=17736016#comment-17736016 ] Tzu-Li (Gordon) Tai commented on FLINK-31731: - Merged for apache/flink via 2

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

[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&focusedCommentId=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&focusedCommentId=17727581#comment-17727581 ] Tzu-Li (Gordon) Tai commented on FLINK-32038: - Hi [~pritam.agarwala], it doe

[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&focusedCommentId=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&focusedCommentId=17726426#comment-17726426 ] Tzu-Li (Gordon) Tai commented on FLINK-32196: - [~sharonxr55] a few things to

[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&focusedCommentId=17726390#comment-17726390 ] Tzu-Li (Gordon) Tai commented on FLINK-32196: - In terms of the lingering tra

[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&focusedCommentId=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&focusedCommentId=17726385#comment-17726385 ] Tzu-Li (Gordon) Tai commented on FLINK-32196: - Hi [~sharonxr55], the {{abort

  1   2   3   4   5   6   7   8   9   10   >