[jira] [Created] (FLINK-26459) Streaming File Sink s3 end-to-end test failed on azure due to not enough resource

2022-03-03 Thread Yun Gao (Jira)
Yun Gao created FLINK-26459: --- Summary: Streaming File Sink s3 end-to-end test failed on azure due to not enough resource Key: FLINK-26459 URL: https://issues.apache.org/jira/browse/FLINK-26459 Project: Flin

[jira] [Created] (FLINK-26460) Fix Unsupported type when convertTypeToSpec: MAP

2022-03-03 Thread tartarus (Jira)
tartarus created FLINK-26460: Summary: Fix Unsupported type when convertTypeToSpec: MAP Key: FLINK-26460 URL: https://issues.apache.org/jira/browse/FLINK-26460 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-26461) Throw CannotPlanException in TableFunction

2022-03-03 Thread Spongebob (Jira)
Spongebob created FLINK-26461: - Summary: Throw CannotPlanException in TableFunction Key: FLINK-26461 URL: https://issues.apache.org/jira/browse/FLINK-26461 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-26462) Release Testing: Running Python UDF in different Execution Mode

2022-03-03 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-26462: Summary: Release Testing: Running Python UDF in different Execution Mode Key: FLINK-26462 URL: https://issues.apache.org/jira/browse/FLINK-26462 Project: Flink

[jira] [Created] (FLINK-26463) TableEnvironmentITCase should use MiniCluster

2022-03-03 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-26463: --- Summary: TableEnvironmentITCase should use MiniCluster Key: FLINK-26463 URL: https://issues.apache.org/jira/browse/FLINK-26463 Project: Flink I

[jira] [Created] (FLINK-26464) Introduce new metrics to represent full checkpoint size

2022-03-03 Thread Yun Tang (Jira)
Yun Tang created FLINK-26464: Summary: Introduce new metrics to represent full checkpoint size Key: FLINK-26464 URL: https://issues.apache.org/jira/browse/FLINK-26464 Project: Flink Issue Type: B

[jira] [Created] (FLINK-26465) Optimize SortMergeReader: use loser tree to reduce comparisons

2022-03-03 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-26465: Summary: Optimize SortMergeReader: use loser tree to reduce comparisons Key: FLINK-26465 URL: https://issues.apache.org/jira/browse/FLINK-26465 Project: Flink

[jira] [Created] (FLINK-26466) Wrong dependency in pyflink: Broken toolchain: cannot link a simple C++ program. note: A compiler with support for C++11 language features is required.

2022-03-03 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-26466: - Summary: Wrong dependency in pyflink: Broken toolchain: cannot link a simple C++ program. note: A compiler with support for C++11 language features is required. Key: FLINK-26466

[jira] [Created] (FLINK-26467) Compile RowDataToStringConverter lazily

2022-03-03 Thread Timo Walther (Jira)
Timo Walther created FLINK-26467: Summary: Compile RowDataToStringConverter lazily Key: FLINK-26467 URL: https://issues.apache.org/jira/browse/FLINK-26467 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26468) Test default binding to localhost

2022-03-03 Thread Mika Naylor (Jira)
Mika Naylor created FLINK-26468: --- Summary: Test default binding to localhost Key: FLINK-26468 URL: https://issues.apache.org/jira/browse/FLINK-26468 Project: Flink Issue Type: Improvement

[ANNOUNCE] New Apache Flink Committer - Martijn Visser

2022-03-03 Thread Robert Metzger
Hi everyone, On behalf of the PMC, I'm very happy to announce Martijn Visser as a new Flink committer. Martijn is a very active Flink community member, driving a lot of efforts on the dev@flink mailing list. He also pushes projects such as replacing Google Analytics with Matomo, so that we can ge

[jira] [Created] (FLINK-26469) Adaptive job shows error when not enough resource are available

2022-03-03 Thread Niklas Semmler (Jira)
Niklas Semmler created FLINK-26469: -- Summary: Adaptive job shows error when not enough resource are available Key: FLINK-26469 URL: https://issues.apache.org/jira/browse/FLINK-26469 Project: Flink

Re: Help with pom dependencies for Flink with Table

2022-03-03 Thread Adesh Dsilva
Hi Thank you very much for your reply. A complete reset with a fresh pom fixed this. Like you said I think I had messed up some dependencies On Wed, 2 Mar 2022, 21:49 Jing Ge, wrote: > Hi Adesh, > > have you tried building your project with a clean classpath, i.e. mvn clean > ...? Additionally

[jira] [Created] (FLINK-26470) [Java][TypeExtractor] Missing type information in POJO types of some types (List, Map, UUID)

2022-03-03 Thread Antoine Michaud (Jira)
Antoine Michaud created FLINK-26470: --- Summary: [Java][TypeExtractor] Missing type information in POJO types of some types (List, Map, UUID) Key: FLINK-26470 URL: https://issues.apache.org/jira/browse/FLINK-26470

[jira] [Created] (FLINK-26471) Deleting the operator while jobs are running causes the jobs to fail

2022-03-03 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-26471: -- Summary: Deleting the operator while jobs are running causes the jobs to fail Key: FLINK-26471 URL: https://issues.apache.org/jira/browse/FLINK-26471 Project: Flink

[jira] [Created] (FLINK-26472) Introduce Savepoint object in JobStatus

2022-03-03 Thread Matyas Orhidi (Jira)
Matyas Orhidi created FLINK-26472: - Summary: Introduce Savepoint object in JobStatus Key: FLINK-26472 URL: https://issues.apache.org/jira/browse/FLINK-26472 Project: Flink Issue Type: Sub-tas

Re: [ANNOUNCE] New Apache Flink Committer - Martijn Visser

2022-03-03 Thread Austin Cawley-Edwards
Congrats Martijn! On Thu, Mar 3, 2022 at 10:50 AM Robert Metzger wrote: > Hi everyone, > > On behalf of the PMC, I'm very happy to announce Martijn Visser as a new > Flink committer. > > Martijn is a very active Flink community member, driving a lot of efforts > on the dev@flink mailing list. He

Re: [ANNOUNCE] New Apache Flink Committer - Martijn Visser

2022-03-03 Thread Leonard Xu
Congratulations and well deserved Martjin ! Best, Leonard > 2022年3月4日 上午7:55,Austin Cawley-Edwards 写道: > > Congrats Martijn! > > On Thu, Mar 3, 2022 at 10:50 AM Robert Metzger wrote: > >> Hi everyone, >> >> On behalf of the PMC, I'm very happy to announce Martijn Visser as a new >> Flink c

Re: [ANNOUNCE] New Apache Flink Committer - Martijn Visser

2022-03-03 Thread Qingsheng Ren
Congratulations Martijn! Best regards, Qingsheng Ren > On Mar 4, 2022, at 9:56 AM, Leonard Xu wrote: > > Congratulations and well deserved Martjin ! > > Best, > Leonard > >> 2022年3月4日 上午7:55,Austin Cawley-Edwards 写道: >> >> Congrats Martijn! >> >> On Thu, Mar 3, 2022 at 10:50 AM Robert

Re: [ANNOUNCE] New Apache Flink Committer - Martijn Visser

2022-03-03 Thread Zhipeng Zhang
Congratulations Martijn! Qingsheng Ren 于2022年3月4日周五 10:14写道: > Congratulations Martijn! > > Best regards, > > Qingsheng Ren > > > On Mar 4, 2022, at 9:56 AM, Leonard Xu wrote: > > > > Congratulations and well deserved Martjin ! > > > > Best, > > Leonard > > > >> 2022年3月4日 上午7:55,Austin Cawley-E

Re: [ANNOUNCE] New Apache Flink Committer - Martijn Visser

2022-03-03 Thread Yu Li
Congratulations! Best Regards, Yu On Fri, 4 Mar 2022 at 10:31, Zhipeng Zhang wrote: > Congratulations Martijn! > > Qingsheng Ren 于2022年3月4日周五 10:14写道: > > > Congratulations Martijn! > > > > Best regards, > > > > Qingsheng Ren > > > > > On Mar 4, 2022, at 9:56 AM, Leonard Xu wrote: > > > > >

Re: [ANNOUNCE] New Apache Flink Committer - Martijn Visser

2022-03-03 Thread Lincoln Lee
Congratulations Martijn! Best, Lincoln Lee Yu Li 于2022年3月4日周五 11:09写道: > Congratulations! > > Best Regards, > Yu > > > On Fri, 4 Mar 2022 at 10:31, Zhipeng Zhang > wrote: > > > Congratulations Martijn! > > > > Qingsheng Ren 于2022年3月4日周五 10:14写道: > > > > > Congratulations Martijn! > > > > > >

[jira] [Created] (FLINK-26473) Observer should support JobManager deployment crashed or deleted externally

2022-03-03 Thread Yang Wang (Jira)
Yang Wang created FLINK-26473: - Summary: Observer should support JobManager deployment crashed or deleted externally Key: FLINK-26473 URL: https://issues.apache.org/jira/browse/FLINK-26473 Project: Flink

Re: [ANNOUNCE] New Apache Flink Committer - Martijn Visser

2022-03-03 Thread Yangze Guo
Congratulations! Best, Yangze Guo On Fri, Mar 4, 2022 at 11:23 AM Lincoln Lee wrote: > > Congratulations Martijn! > > Best, > Lincoln Lee > > > Yu Li 于2022年3月4日周五 11:09写道: > > > Congratulations! > > > > Best Regards, > > Yu > > > > > > On Fri, 4 Mar 2022 at 10:31, Zhipeng Zhang > > wrote: > >

[jira] [Created] (FLINK-26474) Fail to call hive udf when secondary parameter required constant but pass value like "-1"

2022-03-03 Thread luoyuxia (Jira)
luoyuxia created FLINK-26474: Summary: Fail to call hive udf when secondary parameter required constant but pass value like "-1" Key: FLINK-26474 URL: https://issues.apache.org/jira/browse/FLINK-26474 Pr

[jira] [Created] (FLINK-26475) FileStoreScan supports delta consuming

2022-03-03 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-26475: Summary: FileStoreScan supports delta consuming Key: FLINK-26475 URL: https://issues.apache.org/jira/browse/FLINK-26475 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26476) Introduce flink-kubernetes-shaded to avoid overlapping classes

2022-03-03 Thread Yang Wang (Jira)
Yang Wang created FLINK-26476: - Summary: Introduce flink-kubernetes-shaded to avoid overlapping classes Key: FLINK-26476 URL: https://issues.apache.org/jira/browse/FLINK-26476 Project: Flink Iss

Re: [ANNOUNCE] New Apache Flink Committer - Martijn Visser

2022-03-03 Thread Yang Wang
Congratulations Martijn! Best, Yang Yangze Guo 于2022年3月4日周五 11:33写道: > Congratulations! > > Best, > Yangze Guo > > On Fri, Mar 4, 2022 at 11:23 AM Lincoln Lee > wrote: > > > > Congratulations Martijn! > > > > Best, > > Lincoln Lee > > > > > > Yu Li 于2022年3月4日周五 11:09写道: > > > > > Congratulati

Re: [ANNOUNCE] New Apache Flink Committer - Martijn Visser

2022-03-03 Thread Jingsong Li
Congratulations Martijn! Best, Jingsong On Fri, Mar 4, 2022 at 1:09 PM Yang Wang wrote: > > Congratulations Martijn! > > Best, > Yang > > Yangze Guo 于2022年3月4日周五 11:33写道: > > > Congratulations! > > > > Best, > > Yangze Guo > > > > On Fri, Mar 4, 2022 at 11:23 AM Lincoln Lee > > wrote: > > > >

Re: [ANNOUNCE] New Apache Flink Committer - Martijn Visser

2022-03-03 Thread Lijie Wang
Congratulations Martijn! Best, Lijie Jingsong Li 于2022年3月4日周五 13:42写道: > Congratulations Martijn! > > Best, > Jingsong > > On Fri, Mar 4, 2022 at 1:09 PM Yang Wang wrote: > > > > Congratulations Martijn! > > > > Best, > > Yang > > > > Yangze Guo 于2022年3月4日周五 11:33写道: > > > > > Congratulations

[jira] [Created] (FLINK-26477) Finalize the window support in Python DataStream API

2022-03-03 Thread Dian Fu (Jira)
Dian Fu created FLINK-26477: --- Summary: Finalize the window support in Python DataStream API Key: FLINK-26477 URL: https://issues.apache.org/jira/browse/FLINK-26477 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-26478) Support evictor in Python DataStream API

2022-03-03 Thread Dian Fu (Jira)
Dian Fu created FLINK-26478: --- Summary: Support evictor in Python DataStream API Key: FLINK-26478 URL: https://issues.apache.org/jira/browse/FLINK-26478 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26479) Add time_window and count_window in KeyedStream in Python DataStream API

2022-03-03 Thread Dian Fu (Jira)
Dian Fu created FLINK-26479: --- Summary: Add time_window and count_window in KeyedStream in Python DataStream API Key: FLINK-26479 URL: https://issues.apache.org/jira/browse/FLINK-26479 Project: Flink

[jira] [Created] (FLINK-26480) Support window_all in Python DataStream API

2022-03-03 Thread Dian Fu (Jira)
Dian Fu created FLINK-26480: --- Summary: Support window_all in Python DataStream API Key: FLINK-26480 URL: https://issues.apache.org/jira/browse/FLINK-26480 Project: Flink Issue Type: Sub-task

Re: [ANNOUNCE] New Apache Flink Committer - Martijn Visser

2022-03-03 Thread Jiangang Liu
Congratulations Martijn! Best Liu Jiangang Lijie Wang 于2022年3月4日周五 14:00写道: > Congratulations Martijn! > > Best, > Lijie > > Jingsong Li 于2022年3月4日周五 13:42写道: > > > Congratulations Martijn! > > > > Best, > > Jingsong > > > > On Fri, Mar 4, 2022 at 1:09 PM Yang Wang wrote: > > > > > > Congratu

[jira] [Created] (FLINK-26481) Support side output for windowing in Python DataStream API

2022-03-03 Thread Dian Fu (Jira)
Dian Fu created FLINK-26481: --- Summary: Support side output for windowing in Python DataStream API Key: FLINK-26481 URL: https://issues.apache.org/jira/browse/FLINK-26481 Project: Flink Issue Type:

[jira] [Created] (FLINK-26482) Support WindowedStream.reduce in Python DataStream API

2022-03-03 Thread Dian Fu (Jira)
Dian Fu created FLINK-26482: --- Summary: Support WindowedStream.reduce in Python DataStream API Key: FLINK-26482 URL: https://issues.apache.org/jira/browse/FLINK-26482 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-26483) Support WindowedStream.aggregate in Python DataStream API

2022-03-03 Thread Dian Fu (Jira)
Dian Fu created FLINK-26483: --- Summary: Support WindowedStream.aggregate in Python DataStream API Key: FLINK-26483 URL: https://issues.apache.org/jira/browse/FLINK-26483 Project: Flink Issue Type: S

[jira] [Created] (FLINK-26484) BlobServer cleanup does not work for the presto filesystem

2022-03-03 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-26484: - Summary: BlobServer cleanup does not work for the presto filesystem Key: FLINK-26484 URL: https://issues.apache.org/jira/browse/FLINK-26484 Project: Flink

[DISUCSS] When timestamp - offset + windowSize < 0, elements cannot be assigned to the correct window

2022-03-03 Thread 邓子琦
I have created an issue on jira https://issues.apache.org/jira/projects/FLINK/issues/FLINK-26334 issue Hello! When we were studying the flink source code, we found that there was a problem with its algorithm for calculating the window start time. When *timestamp - offset + windowS

Re: [ANNOUNCE] New Apache Flink Committer - Martijn Visser

2022-03-03 Thread David Morávek
Congratulations Martijn, well deserved! Best, D. On Fri, Mar 4, 2022 at 7:25 AM Jiangang Liu wrote: > Congratulations Martijn! > > Best > Liu Jiangang > > Lijie Wang 于2022年3月4日周五 14:00写道: > > > Congratulations Martijn! > > > > Best, > > Lijie > > > > Jingsong Li 于2022年3月4日周五 13:42写道: > > > >

Re: [ANNOUNCE] New Apache Flink Committer - Martijn Visser

2022-03-03 Thread Sergey Nuyanzin
Congratulations Martijn! On Fri, Mar 4, 2022 at 8:07 AM David Morávek wrote: > Congratulations Martijn, well deserved! > > Best, > D. > > On Fri, Mar 4, 2022 at 7:25 AM Jiangang Liu > wrote: > > > Congratulations Martijn! > > > > Best > > Liu Jiangang > > > > Lijie Wang 于2022年3月4日周五 14:00写道: >

Re: [ANNOUNCE] New Apache Flink Committer - Martijn Visser

2022-03-03 Thread Roman Khachatryan
Congratulations Martijn! Regards, Roman On Fri, Mar 4, 2022 at 8:09 AM Sergey Nuyanzin wrote: > > Congratulations Martijn! > > On Fri, Mar 4, 2022 at 8:07 AM David Morávek wrote: > > > Congratulations Martijn, well deserved! > > > > Best, > > D. > > > > On Fri, Mar 4, 2022 at 7:25 AM Jiangang L

Re: Re: [ANNOUNCE] New Apache Flink Committer - Martijn Visser

2022-03-03 Thread Yun Gao
Congratulations Martijn! Best, Yun Gao --Original Mail -- Sender:Roman Khachatryan Send Date:Fri Mar 4 15:22:08 2022 Recipients:dev Subject:Re: [ANNOUNCE] New Apache Flink Committer - Martijn Visser Congratulations Martijn! Regards, Roman On Fri, Mar 4, 2022

[jira] [Created] (FLINK-26485) [Changelog] State not discarded after multiple retries

2022-03-03 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-26485: - Summary: [Changelog] State not discarded after multiple retries Key: FLINK-26485 URL: https://issues.apache.org/jira/browse/FLINK-26485 Project: Flink

Re: Re: [ANNOUNCE] New Apache Flink Committer - Martijn Visser

2022-03-03 Thread Konstantin Knauf
Congratulations, Martijn. Well deserved! On Fri, Mar 4, 2022 at 8:26 AM Yun Gao wrote: > Congratulations Martijn! > > Best, > Yun Gao > > > --Original Mail -- > Sender:Roman Khachatryan > Send Date:Fri Mar 4 15:22:08 2022 > Recipients:dev > Subject:Re: [ANNOUNC

[jira] [Created] (FLINK-26486) The operator restart ingress is lost

2022-03-03 Thread leinenglian (Jira)
leinenglian created FLINK-26486: --- Summary: The operator restart ingress is lost Key: FLINK-26486 URL: https://issues.apache.org/jira/browse/FLINK-26486 Project: Flink Issue Type: Bug

Re: [ANNOUNCE] New Apache Flink Committer - Martijn Visser

2022-03-03 Thread Ingo Bürk
Congrats, Martijn! On 03.03.22 16:49, Robert Metzger wrote: Hi everyone, On behalf of the PMC, I'm very happy to announce Martijn Visser as a new Flink committer. Martijn is a very active Flink community member, driving a lot of efforts on the dev@flink mailing list. He also pushes projects su

[jira] [Created] (FLINK-26487) Upgrade to Operator SDK 2.2.0 and replace custom informereventsource logic

2022-03-03 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-26487: -- Summary: Upgrade to Operator SDK 2.2.0 and replace custom informereventsource logic Key: FLINK-26487 URL: https://issues.apache.org/jira/browse/FLINK-26487 Project: Flink