[jira] [Updated] (FLINK-32828) Kafka partition aware watermark not handled correctly shortly after job start up from checkpoint or savepoint

2024-05-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-32828: --- Priority: Critical (was: Major) > Kafka partition aware watermark not handled correctly sho

[jira] [Updated] (FLINK-32828) Kafka partition aware watermark not handled correctly shortly after job start up from checkpoint or savepoint

2024-05-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-32828: --- Affects Version/s: 1.18.1 1.19.0 > Kafka partition aware watermark no

[jira] [Updated] (FLINK-32828) Kafka partition aware watermark not handled correctly shortly after job start up from checkpoint or savepoint

2023-08-11 Thread Grzegorz Liter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grzegorz Liter updated FLINK-32828: --- Description: When using KafkaSource with partition aware watermarks. Watermarks are being e

[jira] [Updated] (FLINK-32828) Kafka partition aware watermark not handled correctly shortly after job start up from checkpoint or savepoint

2023-08-10 Thread Grzegorz Liter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grzegorz Liter updated FLINK-32828: --- Description: When using KafkaSource with partition aware watermarks. Watermarks are being e

[jira] [Updated] (FLINK-32828) Kafka partition aware watermark not handled correctly shortly after job start up from checkpoint or savepoint

2023-08-10 Thread Grzegorz Liter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grzegorz Liter updated FLINK-32828: --- Summary: Kafka partition aware watermark not handled correctly shortly after job start up fr