[DISCUSS] Generalized incremental checkpoint addition monitoring

2021-09-12 Thread yuluoxinsheng

[jira] [Created] (FLINK-24259) Exception thrown when Kafka topic is null for FlinkKafkaConsumer

2021-09-12 Thread Mans Singh (Jira)
Mans Singh created FLINK-24259: -- Summary: Exception thrown when Kafka topic is null for FlinkKafkaConsumer Key: FLINK-24259 URL: https://issues.apache.org/jira/browse/FLINK-24259 Project: Flink

[jira] [Created] (FLINK-24260) py35-cython fails due to could not find requests>=2.26.0

2021-09-12 Thread Xintong Song (Jira)
Xintong Song created FLINK-24260: Summary: py35-cython fails due to could not find requests>=2.26.0 Key: FLINK-24260 URL: https://issues.apache.org/jira/browse/FLINK-24260 Project: Flink Issu

[jira] [Created] (FLINK-24261) KafkaSourceITCase.testMultipleSplits fails due to "Cannot create topic"

2021-09-12 Thread Xintong Song (Jira)
Xintong Song created FLINK-24261: Summary: KafkaSourceITCase.testMultipleSplits fails due to "Cannot create topic" Key: FLINK-24261 URL: https://issues.apache.org/jira/browse/FLINK-24261 Project: Flin

[jira] [Created] (FLINK-24262) Remove unused ContainerOverlays

2021-09-12 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-24262: -- Summary: Remove unused ContainerOverlays Key: FLINK-24262 URL: https://issues.apache.org/jira/browse/FLINK-24262 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-24263) PulsarSourceITCase.testMultipleSplits fails due to "Consumer not found"

2021-09-12 Thread Xintong Song (Jira)
Xintong Song created FLINK-24263: Summary: PulsarSourceITCase.testMultipleSplits fails due to "Consumer not found" Key: FLINK-24263 URL: https://issues.apache.org/jira/browse/FLINK-24263 Project: Flin

[jira] [Created] (FLINK-24264) Streaming File Sink s3 end-to-end test fail with output mismatch

2021-09-12 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-24264: Summary: Streaming File Sink s3 end-to-end test fail with output mismatch Key: FLINK-24264 URL: https://issues.apache.org/jira/browse/FLINK-24264 Project: Fli

[jira] [Created] (FLINK-24265) Streaming File Sink s3 end-to-end test fails due to Output hash mismatch

2021-09-12 Thread Xintong Song (Jira)
Xintong Song created FLINK-24265: Summary: Streaming File Sink s3 end-to-end test fails due to Output hash mismatch Key: FLINK-24265 URL: https://issues.apache.org/jira/browse/FLINK-24265 Project: Fl

[jira] [Created] (FLINK-24266) Log improvement for aborting checkpoint due to tasks are finishing

2021-09-12 Thread Yun Gao (Jira)
Yun Gao created FLINK-24266: --- Summary: Log improvement for aborting checkpoint due to tasks are finishing Key: FLINK-24266 URL: https://issues.apache.org/jira/browse/FLINK-24266 Project: Flink Iss

[jira] [Created] (FLINK-24267) PyFlink Table API example from docs does not work.

2021-09-12 Thread Xintong Song (Jira)
Xintong Song created FLINK-24267: Summary: PyFlink Table API example from docs does not work. Key: FLINK-24267 URL: https://issues.apache.org/jira/browse/FLINK-24267 Project: Flink Issue Type

[jira] [Created] (FLINK-24268) Documentation for building PyFlink does not show correctly.

2021-09-12 Thread Xintong Song (Jira)
Xintong Song created FLINK-24268: Summary: Documentation for building PyFlink does not show correctly. Key: FLINK-24268 URL: https://issues.apache.org/jira/browse/FLINK-24268 Project: Flink