[jira] [Created] (FLINK-37859) [umbrella] FLIP-516: Streaming Multi-Way Join Optimization

dalongliu created FLINK-37859: - Summary: [umbrella] FLIP-516: Streaming Multi-Way Join Optimization Key: FLINK-37859 URL: https://issues.apache.org/jira/browse/FLINK-37859 Project: Flink Issue Ty

[RESULT][VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join

Hi All, The voting [1] on FLIP-497: Early Fire Support for Flink SQL Interval Join [2] has concluded with the following result: Approving votes: Jiangjie (Becket) Qin (binding) Venkata Krishnan (non-binding) Xingcan Cui (binding) Xuyang (binding) There were no disapproving votes, so I’m happy to

Re: [DISCUSS] Deprecating/dropping support for Python 3.8

Hi Mika, +1 to drop and not just deprecate from my side. BR, G On Wed, May 28, 2025 at 7:06 AM Dian Fu wrote: > Hi Mika, > > Thanks for bringing up this discussion. > > Regarding dropping support of Python 3.8: +1 for this. Since we will > add support for Python 3.12 in Flink 2.1[1], this mea

Re: [DISCUSS] Deprecating/dropping support for Python 3.8

Hi Mika, Thanks for bringing up this discussion. Regarding dropping support of Python 3.8: +1 for this. Since we will add support for Python 3.12 in Flink 2.1[1], this means we need to maintain 5 Python versions if we still support Python 3.8. Considering that 3.8 is already EOL and the issue you

Re: [VOTE] FLIP-313: Add support of User Defined AsyncTableFunction

Hi Timo and Alan, Thanks for replying. I totally understand that we wanted to create a new FLIP as this one is inactive for a long time. I was confused mainly because the FLIP-313 status still shows as active. Anyways, I just started a discussion thread in the dev mailing list to propose some conv

[DISCUSSION] FLIP Process - Handling similar FLIPs and dormant FLIPs

Hi Folks, In a recent discussion of reviving FLIP-313, I realized that we do not have an established convention in handling dormant FLIPs (FLIPs without interaction for months, even years) or FLIPs addressing the same issues. To give a more concrete context, let's take a look at the example case

Re: [DISCUSS] Update Kubernetes operator minimum JDK runtime to 17

Hi Gyula, Thanks for the discussion. I have no immediate concerns with the proper documentation when releasing 1.13.0. We have a custom build that we could beta test with prior to finalizing the 1.13.0 release. Ryan van Huuksloot Sr. Production Engineer | Streaming Platform [image: Shopify]

Re: [DISCUSS] FLIP-531: Initiate Flink Agents as a new Sub-Project

Thanks everyone for the positive feedback. It seems to me most people are in support of this proposal. I'll wait for a couple of more days, and then start the vote if no more concern is raised. Best, Xintong On Mon, May 26, 2025 at 3:09 PM Jing Ge wrote: > Fair enough! Thanks Xintong for

Re: [DISCUSS] Deprecating/dropping support for Python 3.8

Hi Mika, Thank you very much for initiating this discussion. We did not have very strict rules for deprecating Python versions before, but we usually chose to start deprecation about a year after EOF and stop supporting the Python version in the next Flink version. The reason why we started deprec

[jira] [Created] (FLINK-37857) Add a DSV2 sink implementation to tests which can collect data

Gabor Somogyi created FLINK-37857: - Summary: Add a DSV2 sink implementation to tests which can collect data Key: FLINK-37857 URL: https://issues.apache.org/jira/browse/FLINK-37857 Project: Flink

[jira] [Created] (FLINK-37858) Migrate state processor API from source v1 to source v2 API

Gabor Somogyi created FLINK-37858: - Summary: Migrate state processor API from source v1 to source v2 API Key: FLINK-37858 URL: https://issues.apache.org/jira/browse/FLINK-37858 Project: Flink

Code review request: GCS integration tests and library upgrade

Hello Flink community, I have opened JIRA issues and pull requests for 1) expanded integration test coverage for the GCS FileSystem, followed by 2) an upgrade of the GCS client and FileSystem implementation: https://issues.apache.org/jira/browse/FLINK-37247 https://github.com/apache/flink/pull/2

Re: Getting "sun.rmi.registry is not visible" exception while running main method of CliFrontend.java class of flink-clients package

Hi Ferenc, Thank you for replying! I am using Oracle OpenJDK 17.0.10, and Maven is being picked up from the .mvnw (3.8.6) wrapper. On my local machine, the Maven version is 3.9.9. Scala compiler version is also pointing to the same SDK. I tried all the things that you suggested, like invalidatin

Re: [VOTE] FLIP-313: Add support of User Defined AsyncTableFunction

Hi Becket, Timo, I just wanted to jump in as well, as the author of FLIP-498. This FLIP has been subsumed by FLIP-498: AsyncTableFunction for async > table function support [1]. In the discussion for FLIP-498, we decided > to discard FLIP-313 as it has been abandoned for a while. This was the i

Re: [VOTE] FLIP-313: Add support of User Defined AsyncTableFunction

Hi Becket, sorry if my -1 was too rude in this case. I thought the VOTE is just outdated and should be restarted, including a fresh FLIP number and discussion for it. If it is just about the hint based options approach, I don't have a strong opinion and I'm sure we can evolve FLIP-498 furthe

Re: [DISCUSS] FLIP-XXX: Flink Events Reporter System

Hi Li, Thanks for the positive feedback on the FLIP! I appreciate you taking the time. Glad you see the potential, especially for autonomous operations - it's a key driver. Your question on the Kafka reporter is great; it'll be a vital implementation. V1's core goal is to establish the right foun

RE: [DISCUSS] Deprecating/dropping support for Python 3.8

+1 I'd support dropping EOL python versions from the next / latest flink version. Users who end up on older python versions will need to spend time to update their flink versions and can always continue using older versions until they are ready to upgrade. Dropping old versions on the master branch

Subject: [PR][FLINK-37125] Looking for committer review/merge for PR #26037

Hi everyone, I’ve opened PR #26037 to address a NumberFormatException in the log configuration (see FLINK-37125 ). Davidradl has already reviewed the changes Could someone with committer rights take a

[jira] [Created] (FLINK-37856) Sink option hints are not present in compiled plan

Arvid Heise created FLINK-37856: --- Summary: Sink option hints are not present in compiled plan Key: FLINK-37856 URL: https://issues.apache.org/jira/browse/FLINK-37856 Project: Flink Issue Type:

[DISCUSS] Update Kubernetes operator minimum JDK runtime to 17

Hi all, Attila has been working on upgrading the JOSDK and Fabric8 versions for the Kubernetes operator. The latest version (JOSDK 5.1.0) is no longer compatible with Java 11, so we would like to upgrade the operator runtime to Java 17. The operator runtime version will not affect compatibility

[jira] [Created] (FLINK-37855) Reduce the time cost in MySqlSchemaUtils#listTables

Yanquan Lv created FLINK-37855: -- Summary: Reduce the time cost in MySqlSchemaUtils#listTables Key: FLINK-37855 URL: https://issues.apache.org/jira/browse/FLINK-37855 Project: Flink Issue Type: I