[jira] [Created] (FLINK-36928) Split the action of Epoch into two parts (trigger & final)

2024-12-17 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-36928: --- Summary: Split the action of Epoch into two parts (trigger & final) Key: FLINK-36928 URL: https://issues.apache.org/jira/browse/FLINK-36928 Project: Flink Issu

[jira] [Created] (FLINK-36927) Introduce slicing & one stage Window Aggregate with Async State API

2024-12-17 Thread xuyang (Jira)
xuyang created FLINK-36927: -- Summary: Introduce slicing & one stage Window Aggregate with Async State API Key: FLINK-36927 URL: https://issues.apache.org/jira/browse/FLINK-36927 Project: Flink Issu

[jira] [Created] (FLINK-36926) Introduce Window Join Operator with Async State API

2024-12-17 Thread xuyang (Jira)
xuyang created FLINK-36926: -- Summary: Introduce Window Join Operator with Async State API Key: FLINK-36926 URL: https://issues.apache.org/jira/browse/FLINK-36926 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36925) Introduce SemiAntiJoinOperator in Join with Async State API

2024-12-17 Thread Wang Qilong (Jira)
Wang Qilong created FLINK-36925: --- Summary: Introduce SemiAntiJoinOperator in Join with Async State API Key: FLINK-36925 URL: https://issues.apache.org/jira/browse/FLINK-36925 Project: Flink Is

[jira] [Created] (FLINK-36924) cannot initialize module JavadocMethod - Property 'allowUndeclaredRTE' does not exist, please check the documentation

2024-12-17 Thread luoyuxia (Jira)
luoyuxia created FLINK-36924: Summary: cannot initialize module JavadocMethod - Property 'allowUndeclaredRTE' does not exist, please check the documentation Key: FLINK-36924 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-36923) Bump flink-connector-hbase to Flink 1.19

2024-12-17 Thread Yanquan Lv (Jira)
Yanquan Lv created FLINK-36923: -- Summary: Bump flink-connector-hbase to Flink 1.19 Key: FLINK-36923 URL: https://issues.apache.org/jira/browse/FLINK-36923 Project: Flink Issue Type: New Feature

Re: [DISCUSS] FLIP-494: Add missing createTable/createView methods to TableEnvironment

2024-12-17 Thread Ron Liu
Hi Sergey Thanks for driving this FLIP, +1. It may be a minor typo for the createTable method doc. ``` * {@code * tEnv.createTemporaryTable("MyTable", TableDescriptor.forConnector("datagen") * .schema(Schema.newBuilder() * .column("f0", DataTypes.STRING()) * .build()) * .option(DataGenOpt

[DISCUSS] Flink checkpointInfo and FlinkStateSnapshots

2024-12-17 Thread Michas Szacillo (BLOOMBERG/ 919 3RD A)
Hi all! I recently came across the FlinkStateSnapshot feature which I found quite interesting, but I had a couple questions on its use. 1. In favor of FlinkStateSnapshots, I see that both the checkpointInfo and savepointInfo have been deprecated as part of the JobStatus of FlinkDeployment. Doe

[jira] [Created] (FLINK-36922) Add warning when creating KryoSerializer for generic type

2024-12-17 Thread LEONID ILYEVSKY (Jira)
LEONID ILYEVSKY created FLINK-36922: --- Summary: Add warning when creating KryoSerializer for generic type Key: FLINK-36922 URL: https://issues.apache.org/jira/browse/FLINK-36922 Project: Flink

[DISCUSS] FLIP-494: Add missing createTable/createView methods to TableEnvironment

2024-12-17 Thread Sergey Nuyanzin
Hi all! I would like to open up for discussion another new small FLIP-494[1]. Motivation This FLIP continues the journey of bringing Table API and FlinkSQL closer to each other. It adds missing create methods to TableEnvironment (alter functionality will be added in follow up FLIP(s)). There are

Re: CHI: Automatic Stale PR Cleanup

2024-12-17 Thread Gyula Fóra
Hey! Big +1 I think this is a great initiative and we should follow the path laid down by other projects. Starting with X=1 year and Y=3 months is very forgiving, I personally wouldn't mind immediately going more aggressive to clean up the backlog. So for me X = 6m Y = 3m is also perfectly fine.

Re: [DISCUSS] Flink 1.20.1 release

2024-12-17 Thread Piotr Przybylski
Sure, I created a PR for release-1.20 [1]. This should be also merged to master branch. Shouldn't Flink 2.0 switch to SLF4J 2? I expected this to be the case, but saw that it still uses 1.7. [1] https://github.com/apache/flink/pull/25813 wt., 17 gru 2024 o 13:40 Alexander Fedulov napisał(a): >

Re: CHI: Automatic Stale PR Cleanup

2024-12-17 Thread Jim Hughes
Hi Tom, I like the idea of starting with X=1 year and Y=3 months. That plus having CHI review recent PRs would be helpful. Your suggestion of having a bot which "lints" naming conventions could be useful. Maybe there could be a CHI-bot to automate what you and others are doing manually. :) I wo

CHI: Automatic Stale PR Cleanup

2024-12-17 Thread Tom Cooper
TL;DR - We have over 1.2k open PRs, this is an issue as it makes new contributors think twice about committing and looks like a problem that is too-big-to-solve for committers. - There have been various attempts, over the last 6 years, to enable the Stale PR bot/action to prompt authors to refr

Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler

2024-12-17 Thread Yuepeng Pan
Hi, community, FYI: The proposal change about REST API and backend is extracted into FLIP-495[1][2]. [1] https://cwiki.apache.org/confluence/display/FLINK/%5BWIP%5D+FLIP-495%3A+Support+AdaptiveScheduler+record+and+query+the+rescale+history [2] https://lists.apache.org/thread/t3r9wdd5gpbqnvzw35

[DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history

2024-12-17 Thread Yuepeng Pan
Hi community, We discussed several aspects of FLIP-487[1] 'Show history of rescales in Web UI for AdaptiveScheduler' and received a lot of valuable feedback. Based on the suggestions from the email thread[2], we plan to split the original proposal for FLIP-487[1]. The current email thre

[jira] [Created] (FLINK-36921) AdaptiveExecutionPlanSchedulingContextTest.testGetParallelismAndMaxParallelism fails

2024-12-17 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-36921: -- Summary: AdaptiveExecutionPlanSchedulingContextTest.testGetParallelismAndMaxParallelism fails Key: FLINK-36921 URL: https://issues.apache.org/jira/browse/FLINK-36921

Re: [QUESTION] Several unreleased 1.20.x and and 1.19.x versions in jira

2024-12-17 Thread Alexander Fedulov
Thanks Matthias, no problem! On Tue, 17 Dec 2024 at 12:53, Matthias Pohl wrote: > Yes, you're right. The Jira versions would be valid in that case. > > When I checked on Dec 2, it looked like the discussions on the releases for > 1.20.1 and 1.19.2 were still going on and were not concluded. That

Re: Blue/Green Deployments support for Flink

2024-12-17 Thread Alexander Fedulov
Hi Alex, - Should this reusable ProcessFunction filter out data or simply tag >them? For example, filtering data for green deployments would be > suitable >in the case of Async IO outputs. Could you clarify the idea a bit more, it is not quite clear what you mean. - Should we also

Re: [QUESTION] Several unreleased 1.20.x and and 1.19.x versions in jira

2024-12-17 Thread Matthias Pohl
Yes, you're right. The Jira versions would be valid in that case. When I checked on Dec 2, it looked like the discussions on the releases for 1.20.1 and 1.19.2 were still going on and were not concluded. That's why I removed the versions. Sorry if I misunderstood the state of the releases preparat

Re: [QUESTION] Several unreleased 1.20.x and and 1.19.x versions in jira

2024-12-17 Thread Alexander Fedulov
Hi Sergey and Matthias, I am currently working on 1.19.2 and 1.20.1 releases and the new versions were created in accordance to the release guidelines: https://cwiki.apache.org/confluence/display/FLINK/Creating+a+Flink+Release: Create a new version in JIRA: > With the release currently underway,

Re: [DISCUSS] Flink 1.20.1 release

2024-12-17 Thread Alexander Fedulov
Hi Piotr, Are you willing to look into it and contribute a fix? Best, Alex On Tue, 17 Dec 2024 at 02:32, Piotr Przybylski wrote: > Hello, > > Would it be possible for 1.20.1 to restore compatibility with Logback > (FLINK-36104)? > I didn't see it get any attention, and it breaks deployments /

Re: [DISCUSS] Flink 1.20.1 release

2024-12-17 Thread Ammu P
Hi Alex, Thanks for looking into it. I am able to back port the fix to 1.19.2 as is and a PR[1] is raised for the same. [1] https://github.com/apache/flink/pull/25809 Regards, Ammu > On 17 Dec 2024, at 12:05 AM, Alexander Fedulov > wrote: > > Hi Ammu, > > Thanks for bringing this up. Coul

Re: [VOTE] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment

2024-12-17 Thread Sergey Nuyanzin
yep, you're right Leonard, thanks, I've made a separate one (hope it is ok) On Tue, Dec 17, 2024 at 10:33 AM Leonard Xu wrote: > Minor: A separate email [RESULT][VOTE]FLIP-xxx is recommended. > > Best, > Leonard > > > > On Dec 17, 2024, at 3:54 PM, Sergey Nuyanzin > wrote: > > > > There were 5

[RESULT][VOTE] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment

2024-12-17 Thread Sergey Nuyanzin
Hi everyone, I'm delighted to announce that FLIP-489 [1] has been accepted. There were 5 +1 votes, 4 of which are binding: - Jim Hughes (non-binding) - Timo Walther (binding) - Leonard Xu (binding) - Ron Liu (binding) - Sergey Nuyanzin (binding) There were no -1 votes. Thanks everyone! [1] ht

Re: [VOTE] FLIP-489: Add missing dropTable/dropView methods to TableEnvironment

2024-12-17 Thread Leonard Xu
Minor: A separate email [RESULT][VOTE]FLIP-xxx is recommended. Best, Leonard > On Dec 17, 2024, at 3:54 PM, Sergey Nuyanzin wrote: > > There were 5 +1 votes, 4 of which are binding: > > - Jim Hughes (non-binding) > - Timo Walther (binding) > - Leonard Xu (binding) > - Ron Liu (binding) > - Se

FW: FW: Re: Flink technical debt. Chi meeting

2024-12-17 Thread David Radley
Hello all, We had our 4th Community Health Initiative meeting today. We triaged 19 PRs https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=332500010 In addition to triaging, we talked about: * how could we address the old PRs, and suggested that a bot could be used to close out

[jira] [Created] (FLINK-36920) Update org.quartz-schedule:quartz

2024-12-17 Thread Anupam Aggarwal (Jira)
Anupam Aggarwal created FLINK-36920: --- Summary: Update org.quartz-schedule:quartz Key: FLINK-36920 URL: https://issues.apache.org/jira/browse/FLINK-36920 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-36919) Add missing dropTable/dropView methods to TableEnvironment

2024-12-17 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-36919: --- Summary: Add missing dropTable/dropView methods to TableEnvironment Key: FLINK-36919 URL: https://issues.apache.org/jira/browse/FLINK-36919 Project: Flink