[jira] [Commented] (FLINK-35704) ForkJoinPool introduction to NonSplittingRecursiveEnumerator to vastly improve enumeration performance

[ https://issues.apache.org/jira/browse/FLINK-35704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860159#comment-17860159 ] Grzegorz Liter commented on FLINK-35704: Pull request: https://github.com/apache

[jira] [Created] (FLINK-35704) ForkJoinPool introduction to NonSplittingRecursiveEnumerator to vastly improve enumeration performance

Grzegorz Liter created FLINK-35704: -- Summary: ForkJoinPool introduction to NonSplittingRecursiveEnumerator to vastly improve enumeration performance Key: FLINK-35704 URL: https://issues.apache.org/jira/browse/FLI

[jira] [Commented] (FLINK-34474) After failed deserialization with ConfluentRegistryAvroDeserializationSchema all subsequent deserialization fails

[ https://issues.apache.org/jira/browse/FLINK-34474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818870#comment-17818870 ] Grzegorz Liter commented on FLINK-34474: I also found out that if we deserialize

[jira] [Created] (FLINK-34474) After failed deserialization with ConfluentRegistryAvroDeserializationSchema all subsequent deserialization fails

Grzegorz Liter created FLINK-34474: -- Summary: After failed deserialization with ConfluentRegistryAvroDeserializationSchema all subsequent deserialization fails Key: FLINK-34474 URL: https://issues.apache.org/jira

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

[ 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] [Commented] (FLINK-32828) Kafka partition aware watermark not handled correctly shortly after job start up from checkpoint or savepoint

[ https://issues.apache.org/jira/browse/FLINK-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17752905#comment-17752905 ] Grzegorz Liter commented on FLINK-32828: [~mason6345] its not about idle partiti

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

[ 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

[ 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

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

[ 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 (

[jira] [Created] (FLINK-32828) Kafka-partition-aware watermark not handled correctly shortly after job start up

Grzegorz Liter created FLINK-32828: -- Summary: Kafka-partition-aware watermark not handled correctly shortly after job start up Key: FLINK-32828 URL: https://issues.apache.org/jira/browse/FLINK-32828