[jira] [Created] (FLINK-26745) Unable to create new env

2022-03-20 Thread Rahul Desai (Jira)
Rahul Desai created FLINK-26745: --- Summary: Unable to create new env Key: FLINK-26745 URL: https://issues.apache.org/jira/browse/FLINK-26745 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-26746) Update the documentation of Timer's Fault Tolerance section

2022-03-20 Thread Liwei Lin (Jira)
Liwei Lin created FLINK-26746: - Summary: Update the documentation of Timer's Fault Tolerance section Key: FLINK-26746 URL: https://issues.apache.org/jira/browse/FLINK-26746 Project: Flink Issue

[jira] [Created] (FLINK-26747) [JUnit5 Migration] Module: flink-external-resources

2022-03-20 Thread RocMarshal (Jira)
RocMarshal created FLINK-26747: -- Summary: [JUnit5 Migration] Module: flink-external-resources Key: FLINK-26747 URL: https://issues.apache.org/jira/browse/FLINK-26747 Project: Flink Issue Type: I

[jira] [Created] (FLINK-26748) flink jobmanager metaspace oom

2022-03-20 Thread leishuiyu (Jira)
leishuiyu created FLINK-26748: - Summary: flink jobmanager metaspace oom Key: FLINK-26748 URL: https://issues.apache.org/jira/browse/FLINK-26748 Project: Flink Issue Type: Bug Components

[jira] [Created] (FLINK-26749) Publish the Flink Operator image to public registry

2022-03-20 Thread Xin Hao (Jira)
Xin Hao created FLINK-26749: --- Summary: Publish the Flink Operator image to public registry Key: FLINK-26749 URL: https://issues.apache.org/jira/browse/FLINK-26749 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-26750) HA cluster cleanup not complete

2022-03-20 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-26750: - Summary: HA cluster cleanup not complete Key: FLINK-26750 URL: https://issues.apache.org/jira/browse/FLINK-26750 Project: Flink Issue Type: Bug C

[jira] [Created] (FLINK-26751) [FLIP-171] Kafka implementation of Async Sink

2022-03-20 Thread Almog Tavor (Jira)
Almog Tavor created FLINK-26751: --- Summary: [FLIP-171] Kafka implementation of Async Sink Key: FLINK-26751 URL: https://issues.apache.org/jira/browse/FLINK-26751 Project: Flink Issue Type: New F

[jira] [Created] (FLINK-26752) Online Machine Learning Training

2022-03-20 Thread TheIoTAcademy (Jira)
TheIoTAcademy created FLINK-26752: - Summary: Online Machine Learning Training Key: FLINK-26752 URL: https://issues.apache.org/jira/browse/FLINK-26752 Project: Flink Issue Type: Bug

Re: [VOTE]FLIP-215: Introduce FlinkSessionJob CRD in the kubernetes operator

2022-03-20 Thread Xintong Song
Thanks Aitozi, the FLIP LGTM. +1 (binding) Thank you~ Xintong Song On Fri, Mar 18, 2022 at 10:36 PM Őrhidi Mátyás wrote: > +1 (non-binding) > nice addition to the operator > > Cheers, > Matyas > > On Fri, Mar 18, 2022 at 12:10 PM Biao Geng wrote: > > > +1(non-binding) > > Thanks for the wo

[jira] [Created] (FLINK-26753) PK constraint should include partition key

2022-03-20 Thread Jane Chan (Jira)
Jane Chan created FLINK-26753: - Summary: PK constraint should include partition key Key: FLINK-26753 URL: https://issues.apache.org/jira/browse/FLINK-26753 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26754) KafkaCommitterTest#testRetryCommittableOnRetriableError stuck

2022-03-20 Thread Aitozi (Jira)
Aitozi created FLINK-26754: -- Summary: KafkaCommitterTest#testRetryCommittableOnRetriableError stuck Key: FLINK-26754 URL: https://issues.apache.org/jira/browse/FLINK-26754 Project: Flink Issue Type

[jira] [Created] (FLINK-26755) Cleanup inprogressfileRecoverable for FileSink on restoring

2022-03-20 Thread Yun Gao (Jira)
Yun Gao created FLINK-26755: --- Summary: Cleanup inprogressfileRecoverable for FileSink on restoring Key: FLINK-26755 URL: https://issues.apache.org/jira/browse/FLINK-26755 Project: Flink Issue Type

[jira] [Created] (FLINK-26756) Failed to deserialize for match recognize

2022-03-20 Thread godfrey he (Jira)
godfrey he created FLINK-26756: -- Summary: Failed to deserialize for match recognize Key: FLINK-26756 URL: https://issues.apache.org/jira/browse/FLINK-26756 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-26757) change the default value of state.backend.rocksdb.restore-overlap-fraction-threshold

2022-03-20 Thread Yanfei Lei (Jira)
Yanfei Lei created FLINK-26757: -- Summary: change the default value of state.backend.rocksdb.restore-overlap-fraction-threshold Key: FLINK-26757 URL: https://issues.apache.org/jira/browse/FLINK-26757 Proj

[jira] [Created] (FLINK-26758) [JUnit5 Migration] Module: flink-container

2022-03-20 Thread RocMarshal (Jira)
RocMarshal created FLINK-26758: -- Summary: [JUnit5 Migration] Module: flink-container Key: FLINK-26758 URL: https://issues.apache.org/jira/browse/FLINK-26758 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26759) Legacy source support waiting for recordWriter to be available

2022-03-20 Thread fanrui (Jira)
fanrui created FLINK-26759: -- Summary: Legacy source support waiting for recordWriter to be available Key: FLINK-26759 URL: https://issues.apache.org/jira/browse/FLINK-26759 Project: Flink Issue Typ

Re: [ANNOUNCE] New PMC member: Yuan Mei

2022-03-20 Thread Jingsong Li
Congrats Yuan! Well deserved! Best, Jingsong On Thu, Mar 17, 2022 at 8:37 PM Terry Wang wrote: > > Congratulations Yuan! > > On Tue, Mar 15, 2022 at 5:55 PM Jark Wu wrote: > > > Congrats Yuan! Well deserved! > > > > Best, > > Jark > > > > On Tue, 15 Mar 2022 at 17:42, Qingsheng Ren wrote: > >

[jira] [Created] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

2022-03-20 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-26760: -- Summary: The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8 Key: FLINK-26760 URL: https://issues.apache.org/jira/brow

[jira] [Created] (FLINK-26761) Fix the cast exception thrown by PreValidateReWriter when insert into/overwrite a partitioned table.

2022-03-20 Thread zoucao (Jira)
zoucao created FLINK-26761: -- Summary: Fix the cast exception thrown by PreValidateReWriter when insert into/overwrite a partitioned table. Key: FLINK-26761 URL: https://issues.apache.org/jira/browse/FLINK-26761

[DISCUSS] FLIP-214 Support Advanced Function DDL

2022-03-20 Thread 刘大龙
Hi, everyone I would like to open a discussion for support advanced Function DDL, this proposal is a continuation of FLIP-79 in which Flink Function DDL is defined. Until now it is partially released as the Flink function DDL with user defined resources is not clearly discussed and implement

Re: [VOTE]FLIP-215: Introduce FlinkSessionJob CRD in the kubernetes operator

2022-03-20 Thread Shuiqiang Chen
+1 (non-binding) It will make job management more convenient in session mode. Best, shuiqiang Xintong Song 于2022年3月21日周一 09:57写道： > Thanks Aitozi, the FLIP LGTM. > > +1 (binding) > > Thank you~ > > Xintong Song > > > > On Fri, Mar 18, 2022 at 10:36 PM Őrhidi Mátyás > wrote: > > > +1 (non-bindi