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

2024-01-28 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811642#comment-17811642 ] Kevin Tseng commented on FLINK-33545: - Hi [~mason6345]  I'm not sure that's possibl

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

2024-02-15 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817758#comment-17817758 ] Kevin Tseng commented on FLINK-33545: - Hi [~mason6345] , [~yang]  I have simplified

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

2024-02-20 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819079#comment-17819079 ] Kevin Tseng commented on FLINK-33545: - Hi [~mason6345]  I have replicated the behav

[jira] [Created] (FLINK-33479) Add Rerouting support to KafkaSink

2023-11-07 Thread Kevin Tseng (Jira)
Kevin Tseng created FLINK-33479: --- Summary: Add Rerouting support to KafkaSink Key: FLINK-33479 URL: https://issues.apache.org/jira/browse/FLINK-33479 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-33479) Add Rerouting support to KafkaSink

2023-11-07 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783741#comment-17783741 ] Kevin Tseng commented on FLINK-33479: - can someone assign this to me. we have idea o

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

2023-11-14 Thread Kevin Tseng (Jira)
Kevin Tseng created FLINK-33545: --- Summary: KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching Key: FLINK-33545 URL: https://issues.apache.org/jira/bro

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

2023-11-14 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786084#comment-17786084 ] Kevin Tseng commented on FLINK-33545: - we have a fix to address this issue, can anyo

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

2023-11-14 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Tseng updated FLINK-33545: Description: In the current implementation of KafkaSource and KafkaSink there are some assumption

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

2023-11-14 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Tseng updated FLINK-33545: Description: In the current implementation of KafkaSource and KafkaSink there are some assumption

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

2023-11-14 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786084#comment-17786084 ] Kevin Tseng edited comment on FLINK-33545 at 11/14/23 9:26 PM: ---

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

2023-11-14 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Tseng updated FLINK-33545: Description: In the current implementation of KafkaSource and KafkaSink there are some assumption

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

2023-11-14 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Tseng updated FLINK-33545: Description: In the current implementation of KafkaSource and KafkaSink there are some assumption

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

2023-11-14 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Tseng updated FLINK-33545: Description: In the current implementation of KafkaSource and KafkaSink there are some assumption

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

2023-11-14 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Tseng updated FLINK-33545: Description: In the current implementation of KafkaSource and KafkaSink there are some assumption

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

2023-11-16 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786907#comment-17786907 ] Kevin Tseng edited comment on FLINK-33545 at 11/16/23 7:06 PM: ---

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

2023-11-16 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786907#comment-17786907 ] Kevin Tseng commented on FLINK-33545: - Hi Tzu-Li, Thanks for the response. Below i

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

2023-11-16 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786933#comment-17786933 ] Kevin Tseng commented on FLINK-33545: - I'm also aware of the issue FLINK-31305 i do

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

2023-11-30 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791903#comment-17791903 ] Kevin Tseng edited comment on FLINK-33545 at 12/1/23 5:16 AM:

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

2023-11-30 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791903#comment-17791903 ] Kevin Tseng commented on FLINK-33545: - Hi Mason, thank you for the comment. In the

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

2023-12-06 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17793866#comment-17793866 ] Kevin Tseng commented on FLINK-33545: - Hi Mason, Kafka Producer only throw exceptio

[jira] [Updated] (FLINK-31951) Mix schema record source creates corrupt record

2023-08-11 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Tseng updated FLINK-31951: Fix Version/s: 1.18.0 Labels: fix-provided pull-request-available (was: pull-request-a

[jira] [Resolved] (FLINK-31951) Mix schema record source creates corrupt record

2023-08-23 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Tseng resolved FLINK-31951. - Resolution: Fixed > Mix schema record source creates corrupt record > --

[jira] [Reopened] (FLINK-31951) Mix schema record source creates corrupt record

2023-08-23 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Tseng reopened FLINK-31951: - > Mix schema record source creates corrupt record > ---

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

2024-07-08 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863951#comment-17863951 ] Kevin Tseng commented on FLINK-33545: - Hi [~arvid] , [~masc] , [~thomasWeise]  I ag

[jira] [Created] (FLINK-31951) Mix schema record source creates corrupt record

2023-04-26 Thread Kevin Tseng (Jira)
Kevin Tseng created FLINK-31951: --- Summary: Mix schema record source creates corrupt record Key: FLINK-31951 URL: https://issues.apache.org/jira/browse/FLINK-31951 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-31951) Mix schema record source creates corrupt record

2023-04-26 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17716969#comment-17716969 ] Kevin Tseng commented on FLINK-31951: - can a committer assign this bug to me? As thi