[jira] [Created] (FLINK-35738) Release Testing: Verify FLINK-26050 Too many small sst files in rocksdb state backend when using time window created in ascending order

Rui Fan created FLINK-35738: --- Summary: Release Testing: Verify FLINK-26050 Too many small sst files in rocksdb state backend when using time window created in ascending order Key: FLINK-35738 URL: https://issues.apache.

Re: [VOTE] Release flink-shaded 19.0, release candidate #1

+1 (binding) - Verified hash and signature - Build from source - Verified website PR Best regards, Weijie Martijn Visser 于2024年7月1日周一 21:30写道： > +1 (binding) > > - Validated hashes > - Verified signature > - Verified that no binaries exist in the source archive > - Build the source with Mave

[jira] [Created] (FLINK-35737) Prevent Memory Leak by Closing MemoryExecutionGraphInfoStore on MiniCluster Shutdown

Feng Jiajie created FLINK-35737: --- Summary: Prevent Memory Leak by Closing MemoryExecutionGraphInfoStore on MiniCluster Shutdown Key: FLINK-35737 URL: https://issues.apache.org/jira/browse/FLINK-35737 Pr

Re: [VOTE] FLIP-456: CompiledPlan support for Batch Execution Mode

Hi Alexey, +1 (non-binding) I'm looking forward to parity between streaming and batch bound for compiled plans! Cheers, Jim On Mon, Jul 1, 2024 at 12:55 PM Alexey Leonov-Vendrovskiy < vendrov...@gmail.com> wrote: > Hello everyone, > > We had a good discussion of FLIP-456: CompiledPlan support

[VOTE] FLIP-456: CompiledPlan support for Batch Execution Mode

Hello everyone, We had a good discussion of FLIP-456: CompiledPlan support for Batch Execution Mode [1]. Discussion thread is here: [2]. Let's start voting on it. The vote will be open for at least 72 hours unless there is an objection or insufficient votes. The FLIP will be considered accepted i

Re: [VOTE] Release flink-shaded 19.0, release candidate #1

+1 (binding) - Validated hashes - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven - Verified licenses - Verified web PRs On Fri, Jun 28, 2024 at 2:02 PM Timo Walther wrote: > +1 (binding) > > Thanks for fixing the JSON functions! > > Timo

Re: [VOTE] Release flink-shaded 19.0, release candidate #1

+1 (non-binding) Thanks for driving this - Validated hashes - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven, also built Flink with this version - Verified licenses - Verified web PRs On Fri, Jun 28, 2024 at 2:02 PM Timo Walther wrote: >

[jira] [Created] (FLINK-35736) Add E2e migration scripts for Flink CDC

yux created FLINK-35736: --- Summary: Add E2e migration scripts for Flink CDC Key: FLINK-35736 URL: https://issues.apache.org/jira/browse/FLINK-35736 Project: Flink Issue Type: Improvement Compo

[jira] [Created] (FLINK-35735) Don't list catalogs when closing session

Shengkai Fang created FLINK-35735: - Summary: Don't list catalogs when closing session Key: FLINK-35735 URL: https://issues.apache.org/jira/browse/FLINK-35735 Project: Flink Issue Type: Improv

Re:Re: [DISCUSS] FLIP-466: Introduce ProcessFunction Attribute in DataStream API V2

Hi, Jeyhun, Thanks for the reply. > Integrate these annotations with the execution plan. I believe DataStream is an Imperative API, which means that the actual execution plan is basically consistent with the computational logic expressed by the user with DataStream, and it is different from SQL

Re: [DISCUSS] FLIP-456: Introduce DESCRIBE FUNCTION

Hi Natea, the FLIPs looks good to me. Looking for forward to it. @Feng: TypeInferenceUtil#generateSignature considers parameter names if they have been specified. We can further evolve this function (e.g. improving the result type information), but this is not part of the FLIP. This requires