[jira] [Updated] (FLINK-35565) Flink KafkaSource Batch Job Gets Into Infinite Loop after Resetting Offset

2024-06-11 Thread Naci Simsek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Naci Simsek updated FLINK-35565: Description: h2. Summary Flink batch job gets into an infinite fetch loop and could not gracefull

[jira] [Created] (FLINK-35565) Flink KafkaSource Batch Job Gets Into Infinite Loop after Resetting Offset

2024-06-11 Thread Naci Simsek (Jira)
Naci Simsek created FLINK-35565: --- Summary: Flink KafkaSource Batch Job Gets Into Infinite Loop after Resetting Offset Key: FLINK-35565 URL: https://issues.apache.org/jira/browse/FLINK-35565 Project: Fli

[jira] [Comment Edited] (FLINK-33001) KafkaSource in batch mode failing with exception if topic partition is empty

2024-05-30 Thread Naci Simsek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850678#comment-17850678 ] Naci Simsek edited comment on FLINK-33001 at 5/30/24 1:07 PM:

[jira] [Commented] (FLINK-33001) KafkaSource in batch mode failing with exception if topic partition is empty

2024-05-30 Thread Naci Simsek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850678#comment-17850678 ] Naci Simsek commented on FLINK-33001: - Just be able to try with the *flink-connector

[jira] [Comment Edited] (FLINK-33001) KafkaSource in batch mode failing with exception if topic partition is empty

2024-05-30 Thread Naci Simsek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850678#comment-17850678 ] Naci Simsek edited comment on FLINK-33001 at 5/30/24 10:41 AM: ---

[jira] [Comment Edited] (FLINK-33001) KafkaSource in batch mode failing with exception if topic partition is empty

2024-05-30 Thread Naci Simsek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850678#comment-17850678 ] Naci Simsek edited comment on FLINK-33001 at 5/30/24 10:40 AM: ---