[jira] [Created] (FLINK-35289) Incorrect timestamp of stream elements collected from onTimer in batch mode

2024-05-04 Thread Kanthi Vaidya (Jira)
Kanthi Vaidya created FLINK-35289: - Summary: Incorrect timestamp of stream elements collected from onTimer in batch mode Key: FLINK-35289 URL: https://issues.apache.org/jira/browse/FLINK-35289 Project

[jira] [Commented] (FLINK-35289) Incorrect timestamp of stream elements collected from onTimer in batch mode

2024-05-14 Thread Kanthi Vaidya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846454#comment-17846454 ] Kanthi Vaidya commented on FLINK-35289: --- Any updates on this issue ? > Incorrect

[jira] [Commented] (FLINK-35289) Incorrect timestamp of stream elements collected from onTimer in batch mode

2024-05-15 Thread Kanthi Vaidya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846700#comment-17846700 ] Kanthi Vaidya commented on FLINK-35289: --- If we do: ctx.timerService().registerEven

[jira] [Comment Edited] (FLINK-35289) Incorrect timestamp of stream elements collected from onTimer in batch mode

2024-05-15 Thread Kanthi Vaidya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846700#comment-17846700 ] Kanthi Vaidya edited comment on FLINK-35289 at 5/15/24 4:16 PM: --

[jira] [Comment Edited] (FLINK-35289) Incorrect timestamp of stream elements collected from onTimer in batch mode

2024-05-15 Thread Kanthi Vaidya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846700#comment-17846700 ] Kanthi Vaidya edited comment on FLINK-35289 at 5/15/24 4:21 PM: --

[jira] [Commented] (FLINK-35289) Incorrect timestamp of stream elements collected from onTimer in batch mode

2024-05-15 Thread Kanthi Vaidya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846786#comment-17846786 ] Kanthi Vaidya commented on FLINK-35289: --- package sample; import lombok.extern.slf

[jira] [Comment Edited] (FLINK-35289) Incorrect timestamp of stream elements collected from onTimer in batch mode

2024-05-15 Thread Kanthi Vaidya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846786#comment-17846786 ] Kanthi Vaidya edited comment on FLINK-35289 at 5/16/24 2:22 AM: --

[jira] [Comment Edited] (FLINK-35289) Incorrect timestamp of stream elements collected from onTimer in batch mode

2024-05-15 Thread Kanthi Vaidya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846786#comment-17846786 ] Kanthi Vaidya edited comment on FLINK-35289 at 5/16/24 2:27 AM: --

[jira] [Comment Edited] (FLINK-35289) Incorrect timestamp of stream elements collected from onTimer in batch mode

2024-05-15 Thread Kanthi Vaidya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846786#comment-17846786 ] Kanthi Vaidya edited comment on FLINK-35289 at 5/16/24 2:28 AM: --

[jira] [Comment Edited] (FLINK-35289) Incorrect timestamp of stream elements collected from onTimer in batch mode

2024-05-15 Thread Kanthi Vaidya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846786#comment-17846786 ] Kanthi Vaidya edited comment on FLINK-35289 at 5/16/24 2:29 AM: --

[jira] [Comment Edited] (FLINK-35289) Incorrect timestamp of stream elements collected from onTimer in batch mode

2024-05-15 Thread Kanthi Vaidya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846786#comment-17846786 ] Kanthi Vaidya edited comment on FLINK-35289 at 5/16/24 2:31 AM: --

[jira] [Created] (FLINK-33224) Flink Batch Job does not complete when using Kafka topics with empty partitions

2023-10-09 Thread Kanthi Vaidya (Jira)
Kanthi Vaidya created FLINK-33224: - Summary: Flink Batch Job does not complete when using Kafka topics with empty partitions Key: FLINK-33224 URL: https://issues.apache.org/jira/browse/FLINK-33224 Pr

[jira] [Commented] (FLINK-33224) Flink Batch Job does not complete when using Kafka topics with empty partitions

2023-10-12 Thread Kanthi Vaidya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17774672#comment-17774672 ] Kanthi Vaidya commented on FLINK-33224: --- [~martijnvisser] I am talking about Apach

[jira] [Comment Edited] (FLINK-33224) Flink Batch Job does not complete when using Kafka topics with empty partitions

2023-10-12 Thread Kanthi Vaidya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17774672#comment-17774672 ] Kanthi Vaidya edited comment on FLINK-33224 at 10/12/23 7:49 PM: -