[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

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