[
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
[
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
[
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
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
[
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
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
[
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
[
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
[
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
[
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:
---
[
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
[
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
[
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
[
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
[
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:
---
[
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
[
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
[
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:
[
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
[
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
[
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
[
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
> --
[
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
> ---
[
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
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
[
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
26 matches
Mail list logo