[jira] [Created] (FLINK-22625) FileSinkMigrationITCase unstable

2021-05-10 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22625: Summary: FileSinkMigrationITCase unstable Key: FLINK-22625 URL: https://issues.apache.org/jira/browse/FLINK-22625 Project: Flink Issue Type: Bug

Re: Task Local Recovery with mountable disks in the cloud

2021-05-10 Thread Yang Wang
Just a side input, not only the persistent volume could help with keeping the local state for the TaskManager pod, but also the ephemeral storage. Ephemeral storage is bound to the lifecycle of TaskManager pod. And it could be shared between different restarts of TaskManager container. Best, Yan

[jira] [Created] (FLINK-22624) Default resource allocation strategy will allocate more pending task managers than demand

2021-05-10 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-22624: -- Summary: Default resource allocation strategy will allocate more pending task managers than demand Key: FLINK-22624 URL: https://issues.apache.org/jira/browse/FLINK-22624

[VOTE] Release 1.12.4, release candidate #1

2021-05-10 Thread Arvid Heise
Hi everyone, Please review and vote on the release candidate #1 for the version 1.12.4, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes [1], *

[jira] [Created] (FLINK-22623) Drop BatchTableSource HBaseTableSource

2021-05-10 Thread Timo Walther (Jira)
Timo Walther created FLINK-22623: Summary: Drop BatchTableSource HBaseTableSource Key: FLINK-22623 URL: https://issues.apache.org/jira/browse/FLINK-22623 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-22622) Drop BatchTableSource ParquetTableSource

2021-05-10 Thread Timo Walther (Jira)
Timo Walther created FLINK-22622: Summary: Drop BatchTableSource ParquetTableSource Key: FLINK-22622 URL: https://issues.apache.org/jira/browse/FLINK-22622 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-22621) HBaseConnectorITCase.testTableSourceSinkWithDDL unstable on azure

2021-05-10 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-22621: - Summary: HBaseConnectorITCase.testTableSourceSinkWithDDL unstable on azure Key: FLINK-22621 URL: https://issues.apache.org/jira/browse/FLINK-22621 Project:

Re: About the windowOperator and Watermark

2021-05-10 Thread Dawid Wysakowicz
Hi, When a Watermark arrives the window operator will emit all windows that are considered finished at the time of the Watermark. In your example (assuming both windows are finished) they will both be emitted. Best, Dawid On 08/05/2021 08:03, 曲洋 wrote: > Hi Experts, > > Given that a window in t

[jira] [Created] (FLINK-22620) Uncouple OrcTableSource from legacy planner

2021-05-10 Thread Timo Walther (Jira)
Timo Walther created FLINK-22620: Summary: Uncouple OrcTableSource from legacy planner Key: FLINK-22620 URL: https://issues.apache.org/jira/browse/FLINK-22620 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-22619) Drop usages of BatchTableEnvironment

2021-05-10 Thread Timo Walther (Jira)
Timo Walther created FLINK-22619: Summary: Drop usages of BatchTableEnvironment Key: FLINK-22619 URL: https://issues.apache.org/jira/browse/FLINK-22619 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] Releasing Flink 1.12.4

2021-05-10 Thread Till Rohrmann
+1, thanks Arvid. Cheers, Till On Mon, May 10, 2021 at 5:08 AM Thomas Weise wrote: > +1 > > On Fri, May 7, 2021 at 7:00 AM Konstantin Knauf wrote: > > > +1. Thanks Arvid. > > > > On Fri, May 7, 2021 at 3:56 PM Chesnay Schepler > > wrote: > > > > > +1 for a releasing 1.12.4 ASAP. > > > > > > O

[jira] [Created] (FLINK-22618) Fix incorrect free resource metrics of task managers

2021-05-10 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-22618: -- Summary: Fix incorrect free resource metrics of task managers Key: FLINK-22618 URL: https://issues.apache.org/jira/browse/FLINK-22618 Project: Flink Issue Type:

Re: Task Local Recovery with mountable disks in the cloud

2021-05-10 Thread Till Rohrmann
Hi Sonam, I think it would be great to create a FLIP for this feature. FLIPs don't have to be super large and in this case, I could see it work to express the general idea to make local recovery work across TaskManager failures and then outline the different ideas we had so far. If we then decide

[jira] [Created] (FLINK-22617) Add log when create bulk format

2021-05-10 Thread hehuiyuan (Jira)
hehuiyuan created FLINK-22617: - Summary: Add log when create bulk format Key: FLINK-22617 URL: https://issues.apache.org/jira/browse/FLINK-22617 Project: Flink Issue Type: Bug Componen

[jira] [Created] (FLINK-22616) flink1.13提交任务后,出现以下问题

2021-05-10 Thread Leo (Jira)
Leo created FLINK-22616: --- Summary: flink1.13提交任务后,出现以下问题 Key: FLINK-22616 URL: https://issues.apache.org/jira/browse/FLINK-22616 Project: Flink Issue Type: Bug Environment: CloseableIterator c

[jira] [Created] (FLINK-22615) can't use test harness to test Scala UDF because of two versions of ProcessWindowFunction

2021-05-10 Thread Zhenhao Li (Jira)
Zhenhao Li created FLINK-22615: -- Summary: can't use test harness to test Scala UDF because of two versions of ProcessWindowFunction Key: FLINK-22615 URL: https://issues.apache.org/jira/browse/FLINK-22615