elon_X created FLINK-35685:
--
Summary: Some metrics in the MetricStore are duplicated when
increasing or decreasing task parallelism
Key: FLINK-35685
URL: https://issues.apache.org/jira/browse/FLINK-35685
Pro
elon_X created FLINK-35632:
--
Summary: The example provided in the kafkaSource documentation
for topic regex subscription is incorrect
Key: FLINK-35632
URL: https://issues.apache.org/jira/browse/FLINK-35632
elon_X created FLINK-35631:
--
Summary: KafkaSource parameter partition.discovery.interval.ms
with a default value of 5 minutes does not take effect
Key: FLINK-35631
URL: https://issues.apache.org/jira/browse/FLINK-35631
elon_X created FLINK-35506:
--
Summary: disable kafka auto-commit and rely on flink’s
checkpointing if both are enabled
Key: FLINK-35506
URL: https://issues.apache.org/jira/browse/FLINK-35506
Project: Flink
elon_X created FLINK-35178:
--
Summary: Checkpoint CLAIM mode does not fully control snapshot
ownership
Key: FLINK-35178
URL: https://issues.apache.org/jira/browse/FLINK-35178
Project: Flink
Issue Ty
elon_X created FLINK-35160:
--
Summary: Support for Thread Dump provides a convenient way to
display issues of thread deadlocks in tasks
Key: FLINK-35160
URL: https://issues.apache.org/jira/browse/FLINK-35160
elon_X created FLINK-35088:
--
Summary: watermark alignment maxAllowedWatermarkDrift and
updateInterval param need check
Key: FLINK-35088
URL: https://issues.apache.org/jira/browse/FLINK-35088
Project: Flink
elon_X created FLINK-35076:
--
Summary: Watermark alignment will cause data flow to experience
serious shake
Key: FLINK-35076
URL: https://issues.apache.org/jira/browse/FLINK-35076
Project: Flink
Iss