[jira] [Created] (FLINK-25667) AdaptiveSchedulerTest.testStatusMetrics is not stable

2022-01-16 Thread Yun Gao (Jira)
Yun Gao created FLINK-25667: --- Summary: AdaptiveSchedulerTest.testStatusMetrics is not stable Key: FLINK-25667 URL: https://issues.apache.org/jira/browse/FLINK-25667 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-25666) Remove LegacyTypeInfoDataTypeConverter

2022-01-16 Thread RocMarshal (Jira)
RocMarshal created FLINK-25666: -- Summary: Remove LegacyTypeInfoDataTypeConverter Key: FLINK-25666 URL: https://issues.apache.org/jira/browse/FLINK-25666 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-25665) DistinctITCase.testCorrectnessOfDistinctOnCustomTypeWithTypeExtractor timeout on azure

2022-01-16 Thread Yun Gao (Jira)
Yun Gao created FLINK-25665: --- Summary: DistinctITCase.testCorrectnessOfDistinctOnCustomTypeWithTypeExtractor timeout on azure Key: FLINK-25665 URL: https://issues.apache.org/jira/browse/FLINK-25665 Project

Re: [DISCUSS] FLIP-205: Support cache in DataStream for Batch Processing

2022-01-16 Thread Yun Gao
Hi Xuannan, Very thanks for the detailed explanation and sorry for the very late response. For cached result partition v.s. managed table, I also agree with the current conclusion that they could be differentiated at the moment: cached result partition could be viewed as an internal, lightweig

[jira] [Created] (FLINK-25664) Notify will be not triggered for PipelinedSubpartition if more than one buffer is added during isBlocked == true

2022-01-16 Thread Cai Liuyang (Jira)
Cai Liuyang created FLINK-25664: --- Summary: Notify will be not triggered for PipelinedSubpartition if more than one buffer is added during isBlocked == true Key: FLINK-25664 URL: https://issues.apache.org/jira/browse

Re: [DISCUSS] FLIP-205: Support cache in DataStream for Batch Processing

2022-01-16 Thread Xuannan Su
Hi David, Thanks for pointing out the FLIP-187. After reading the FLIP, I think it can solve the problem of choosing the proper parallelism, and thus it should be fine to not provide the method to set the parallelism of the cache. And you understand of the outcome of this FLIP is correct. If the

[jira] [Created] (FLINK-25663) SqlParse

2022-01-16 Thread Xiang Yang (Jira)
Xiang Yang created FLINK-25663: -- Summary: SqlParse Key: FLINK-25663 URL: https://issues.apache.org/jira/browse/FLINK-25663 Project: Flink Issue Type: Improvement Reporter: Xiang Yang

[jira] [Created] (FLINK-25662) Access KeyedStateStore in WindowAssigner

2022-01-16 Thread Sun Sheng (Jira)
Sun Sheng created FLINK-25662: - Summary: Access KeyedStateStore in WindowAssigner Key: FLINK-25662 URL: https://issues.apache.org/jira/browse/FLINK-25662 Project: Flink Issue Type: Improvement

Re: [DISCUSS] FLIP-210: Change logging level dynamically at runtime

2022-01-16 Thread Wenhao Ji
The FLIP has been marked as rejected. Anyone landing here looking for a solution to change the log level without modifying configuration files may use the existing JMX APIs exposed by log4j2 [1] or logback [2]. [1]: https://logging.apache.org/log4j/2.x/manual/jmx.html [2]: https://logback.qos.ch/

[jira] [Created] (FLINK-25661) Add Custom Fatal Exception handler in AsyncSinkWriter

2022-01-16 Thread Nir Tsruya (Jira)
Nir Tsruya created FLINK-25661: -- Summary: Add Custom Fatal Exception handler in AsyncSinkWriter Key: FLINK-25661 URL: https://issues.apache.org/jira/browse/FLINK-25661 Project: Flink Issue Type: