Re: [Discussion] - Release major Flink version to support JDK 17 (LTS)

2023-04-26 Thread Tamir Sagi
More details about the JDK bug here https://bugs.openjdk.org/browse/JDK-8277529 Related Jira ticket https://issues.apache.org/jira/browse/FLINK-24998 From: Jing Ge via user Sent: Monday, April 24, 2023 11:15 PM To: Chesnay Schepler Cc: Piotr Nowojski ; Alexis Sa

[jira] [Created] (FLINK-31951) Mix schema record source creates corrupt record

2023-04-26 Thread Kevin Tseng (Jira)
Kevin Tseng created FLINK-31951: --- Summary: Mix schema record source creates corrupt record Key: FLINK-31951 URL: https://issues.apache.org/jira/browse/FLINK-31951 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-31950) Introduce StateMetadata and support operator-level state TTL configuration via Compiled Plan

2023-04-26 Thread Jane Chan (Jira)
Jane Chan created FLINK-31950: - Summary: Introduce StateMetadata and support operator-level state TTL configuration via Compiled Plan Key: FLINK-31950 URL: https://issues.apache.org/jira/browse/FLINK-31950

[jira] [Created] (FLINK-31949) The state of CountTumblingWindowAssigner of Python DataStream API were never purged

2023-04-26 Thread Dian Fu (Jira)
Dian Fu created FLINK-31949: --- Summary: The state of CountTumblingWindowAssigner of Python DataStream API were never purged Key: FLINK-31949 URL: https://issues.apache.org/jira/browse/FLINK-31949 Project: Fl

[jira] [Created] (FLINK-31948) Supports triggering CI manually

2023-04-26 Thread Jiang Xin (Jira)
Jiang Xin created FLINK-31948: - Summary: Supports triggering CI manually Key: FLINK-31948 URL: https://issues.apache.org/jira/browse/FLINK-31948 Project: Flink Issue Type: Improvement C

Re: [ANNOUNCE] New Apache Flink PMC Member - Qingsheng Ren

2023-04-26 Thread Ran Tao
Congratulations, Qingsheng! Best Regards, Ran Tao Qingsheng Ren 于2023年4月24日周一 19:53写道: > Thank you all! I'm so honored and happy to work with all contributors in > the Apache Flink community. Let's make Flink better together! > > Cheers, > Qingsheng > > On Mon, Apr 24, 2023 at 3:39 PM Jing Ge

Re: [ANNOUNCE] New Apache Flink PMC Member - Qingsheng Ren

2023-04-26 Thread Mason Chen
Congrats Qingsheng! Best, Mason On Tue, Apr 25, 2023 at 7:33 PM Shengkai Fang wrote: > Congratulations, Qingsheng! > > > Best regards, > Shengkai > > Qingsheng Ren 于2023年4月24日周一 19:53写道: > > > Thank you all! I'm so honored and happy to work with all contributors in > > the Apache Flink communi

Kubernetes Operator 1.5.0 release planning

2023-04-26 Thread Hao t Chang
Agree. I will help.

[jira] [Created] (FLINK-31947) Enable stdout redirect in flink-console.sh

2023-04-26 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-31947: - Summary: Enable stdout redirect in flink-console.sh Key: FLINK-31947 URL: https://issues.apache.org/jira/browse/FLINK-31947 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-31946) DynamoDB Sink Allow Multiple Item Writes

2023-04-26 Thread Curtis Jensen (Jira)
Curtis Jensen created FLINK-31946: - Summary: DynamoDB Sink Allow Multiple Item Writes Key: FLINK-31946 URL: https://issues.apache.org/jira/browse/FLINK-31946 Project: Flink Issue Type: Improv

Re: [DISCUSS] Preventing Mockito usage for the new code with Checkstyle

2023-04-26 Thread Alexander Fedulov
+1 for the proposal, Best, Alex On Wed, 26 Apr 2023 at 15:50, Chesnay Schepler wrote: > * adds a note to not include "import " in the regex" * > > On 26/04/2023 11:22, Maximilian Michels wrote: > > If we ban Mockito imports, I can still write tests using the full > > qualifiers, right? > > > >

Re: [DISCUSS] Preventing Mockito usage for the new code with Checkstyle

2023-04-26 Thread Chesnay Schepler
* adds a note to not include "import " in the regex" * On 26/04/2023 11:22, Maximilian Michels wrote: If we ban Mockito imports, I can still write tests using the full qualifiers, right? For example: org.mockito.Mockito.when(somethingThatShouldHappen).thenReturn(somethingThatNeverActually

Re: [DISCUSS] Planning Flink 2.0

2023-04-26 Thread DONG Weike
Hi, It is thrilling to see the foreseeable upcoming rollouts of Flink 2.x releases, and I believe that this roadmap can take Flink to the next stage of a top-of-notch unified streaming & batch computing engine. Given that all of the existing user programs are written and run in Flink 1.x versi

Re: [DISCUSS] Planning Flink 2.0

2023-04-26 Thread Xintong Song
@Chesnay > Technically this implies that every minor release may contain breaking > changes, which is exactly what users don't want. It's not necessary to introduce the breaking chagnes immediately upon reaching the minimum guaranteed stable time. If there are multiple changes waiting for the s

[RESULT][VOTE] FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source

2023-04-26 Thread Hongshun Wang
Hi everyone, Happy to announce that FLIP-288[1] has been approved unanimously! Voting included 11 votes, out of which 6 were binding -- and no disapproving votes.[2] - Tzu-Li (Gordon) Tai (binding) - Leonard Xu (binding) - Qingsheng Ren(binding) - Shammon FY - Paul Lam - Hang

Re: [VOTE] FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source

2023-04-26 Thread Hongshun Wang
Thanks, everyone, I'm closing this vote now. I'll follow up with the result in a separate email. Best Hongshun On Tue, Apr 25, 2023 at 1:54 PM Jing Ge wrote: > +1(binding) > > Best regards, > Jing > > On Tue, Apr 25, 2023 at 5:17 AM Rui Fan <1996fan...@gmail.com> wrote: > > > +1 (binding) > >

Re: [DISCUSS] Planning Flink 2.0

2023-04-26 Thread Gyula Fóra
+1 to everything Max said. Gyula On Wed, 26 Apr 2023 at 11:42, Maximilian Michels wrote: > Thanks for starting the discussion, Jark and Xingtong! > > Flink 2.0 is long overdue. In the past, the expectations for such a > release were unreasonably high. I think everybody had a different > underst

Re: [DISCUSS] Planning Flink 2.0

2023-04-26 Thread Maximilian Michels
Thanks for starting the discussion, Jark and Xingtong! Flink 2.0 is long overdue. In the past, the expectations for such a release were unreasonably high. I think everybody had a different understanding of what exactly the criteria were. This led to releasing 18 minor releases for the current majo

Re: [DISCUSS] Preventing Mockito usage for the new code with Checkstyle

2023-04-26 Thread Maximilian Michels
If we ban Mockito imports, I can still write tests using the full qualifiers, right? For example: org.mockito.Mockito.when(somethingThatShouldHappen).thenReturn(somethingThatNeverActuallyHappens) Just kidding, +1 on the proposal. -Max On Wed, Apr 26, 2023 at 9:02 AM Panagiotis Garefalakis

[jira] [Created] (FLINK-31945) Table of contents in the blogs of the project website is missing some titles

2023-04-26 Thread Zhilong Hong (Jira)
Zhilong Hong created FLINK-31945: Summary: Table of contents in the blogs of the project website is missing some titles Key: FLINK-31945 URL: https://issues.apache.org/jira/browse/FLINK-31945 Project:

Re: [DISCUSS] Planning Flink 2.0

2023-04-26 Thread Chesnay Schepler
> /Instead of defining compatibility guarantees as "this API won't change in all 1.x/2.x series", what if we define it as "this API won't change in the next 2/3 years"./ I can see some benefits to this approach (all APIs having a fixed minimum lifetime) but it's just gonna be difficult to comm

[jira] [Created] (FLINK-31944) Protobuf format throw com.google.protobuf.InvalidProtocolBufferException

2023-04-26 Thread Xuannan Su (Jira)
Xuannan Su created FLINK-31944: -- Summary: Protobuf format throw com.google.protobuf.InvalidProtocolBufferException Key: FLINK-31944 URL: https://issues.apache.org/jira/browse/FLINK-31944 Project: Flink

Re: [DISCUSS] Preventing Mockito usage for the new code with Checkstyle

2023-04-26 Thread Panagiotis Garefalakis
Thanks for bringing this up! +1 for the proposal @Jing Ge -- we don't necessarily need to completely migrate to Junit5 (even though it would be ideal). We could introduce the checkstyle rule and add suppressions for the existing problematic paths (as we do today for other rules e.g., AvoidStarImp