[jira] [Created] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint

Yordan Pavlov created FLINK-33109: - Summary: Watermark alignment not applied after recovery from checkpoint Key: FLINK-33109 URL: https://issues.apache.org/jira/browse/FLINK-33109 Project: Flink

[jira] [Created] (FLINK-31970) "Key group 0 is not in KeyGroupRange" when using CheckpointedFunction

Yordan Pavlov created FLINK-31970: - Summary: "Key group 0 is not in KeyGroupRange" when using CheckpointedFunction Key: FLINK-31970 URL: https://issues.apache.org/jira/browse/FLINK-31970 Project: Flin

[jira] [Created] (FLINK-31727) Source parallelism should match number of Kafka partitions

Yordan Pavlov created FLINK-31727: - Summary: Source parallelism should match number of Kafka partitions Key: FLINK-31727 URL: https://issues.apache.org/jira/browse/FLINK-31727 Project: Flink

[jira] [Created] (FLINK-31304) Very slow job start if topic has been used before

Yordan Pavlov created FLINK-31304: - Summary: Very slow job start if topic has been used before Key: FLINK-31304 URL: https://issues.apache.org/jira/browse/FLINK-31304 Project: Flink Issue Typ

[jira] [Created] (FLINK-28802) EOFException when recovering from a checkpoint

Yordan Pavlov created FLINK-28802: - Summary: EOFException when recovering from a checkpoint Key: FLINK-28802 URL: https://issues.apache.org/jira/browse/FLINK-28802 Project: Flink Issue Type:

[jira] [Created] (FLINK-20698) A single ojbect is reused among windows with different key

Yordan Pavlov created FLINK-20698: - Summary: A single ojbect is reused among windows with different key Key: FLINK-20698 URL: https://issues.apache.org/jira/browse/FLINK-20698 Project: Flink

[jira] [Created] (FLINK-17800) RocksDB optimizeForPointLookup results in missing time windows

Yordan Pavlov created FLINK-17800: - Summary: RocksDB optimizeForPointLookup results in missing time windows Key: FLINK-17800 URL: https://issues.apache.org/jira/browse/FLINK-17800 Project: Flink