[jira] [Created] (FLINK-20048) Make Approximate Local Recovery Compatible With PipelinedRegionSchedulingStrategy

Yuan Mei created FLINK-20048: Summary: Make Approximate Local Recovery Compatible With PipelinedRegionSchedulingStrategy Key: FLINK-20048 URL: https://issues.apache.org/jira/browse/FLINK-20048 Project: Fl

[jira] [Created] (FLINK-20049) Simplify handling of "request split".

Stephan Ewen created FLINK-20049: Summary: Simplify handling of "request split". Key: FLINK-20049 URL: https://issues.apache.org/jira/browse/FLINK-20049 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-20050) SourceCoordinatorProviderTest.testCheckpointAndReset failed with NullPointerException

Dian Fu created FLINK-20050: --- Summary: SourceCoordinatorProviderTest.testCheckpointAndReset failed with NullPointerException Key: FLINK-20050 URL: https://issues.apache.org/jira/browse/FLINK-20050 Project:

[jira] [Created] (FLINK-20051) SourceReaderTestBase.testAddSplitToExistingFetcher failed with NullPointerException

Dian Fu created FLINK-20051: --- Summary: SourceReaderTestBase.testAddSplitToExistingFetcher failed with NullPointerException Key: FLINK-20051 URL: https://issues.apache.org/jira/browse/FLINK-20051 Project: Fl

[jira] [Created] (FLINK-20052) kafka/gelly pre-commit test failed due to process hang

Yu Li created FLINK-20052: - Summary: kafka/gelly pre-commit test failed due to process hang Key: FLINK-20052 URL: https://issues.apache.org/jira/browse/FLINK-20052 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20053) Add document for file compaction

Jingsong Lee created FLINK-20053: Summary: Add document for file compaction Key: FLINK-20053 URL: https://issues.apache.org/jira/browse/FLINK-20053 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] Releasing Apache Flink 1.11.3

Hi devs, I'd like to provide an update on the progress of preparing release 1.11.3. *Blockers* We currently have 3 remaining blockers. (3 resolved and 1 emerged compared to last week) - [FLINK-19698] Add close() method and onCheckpointComplete() to the Source. The issue has been fixed on the mas

Re: [DISCUSS] FLIP-145: Support SQL windowing table-valued function

Hi all, After some offline discussion and investigation with Timo and Danny, I have updated the FLIP-145. FLIP-145: https://cwiki.apache.org/confluence/display/FLINK/FLIP-145%3A+Support+SQL+windowing+table-valued+function Here are the updates: 1. Add SESSION window syntax and examples. 2. Time A

[ANNOUNCE] Feature Freeze of Flink 1.12

Hi all, Just a quick note that the deadline for merging new features to the master branch for Flink 1.12 has passed: From now on, only bugfixes and documentation fixes and improvements are allowed in. New features merged after this point will be reverted. If you need an exception to this rule, ple

Re: [ANNOUNCE] Feature Freeze of Flink 1.12

FYI: we are starting to prepare the first release candidate(preview-only and only for test purpose). Regards, Dian > 在 2020年11月9日，下午1:21，Robert Metzger 写道： > > Hi all, > > Just a quick note that the deadline for merging new features to the master > branch for Flink 1.12 has passed: From now

[jira] [Created] (FLINK-20054) 3 Level List is not supported in ParquetInputFormat

Zhenqiu Huang created FLINK-20054: - Summary: 3 Level List is not supported in ParquetInputFormat Key: FLINK-20054 URL: https://issues.apache.org/jira/browse/FLINK-20054 Project: Flink Issue T

[jira] [Created] (FLINK-20055) Datadog API Key exposed in Flink JobManager logs

Florian Szabo created FLINK-20055: - Summary: Datadog API Key exposed in Flink JobManager logs Key: FLINK-20055 URL: https://issues.apache.org/jira/browse/FLINK-20055 Project: Flink Issue Type