Re: [DISCUSS] FLIP-XXX: Aligning timeout logic in the AdaptiveScheduler's WaitingForResources and Executing states

Hi Rui, Yes, it's right. We will update the FLIP's parameters table to make it more explicit. Thanks Best, Zdenek On Mon, Aug 5, 2024 at 5:33 AM Rui Fan <1996fan...@gmail.com> wrote: > Thanks Zdenek Tison and Mattias for driving this proposal! > It's indeed a great improvement for Adaptive Sch

Re: Discussion on Vertica-Flink Connector

Hello, We are looking forward to creating FLIP for voting. Can someone help me with creating the FLIP since now we don't have access to Confluence and need someone's help to create it. Vikas Garg General Engineering | General Engineering Mobile: (+91) 9811716552 LinkedIn: https://www.

Re: [DISCUSS] FLIP-XXX: Aligning timeout logic in the AdaptiveScheduler's WaitingForResources and Executing states

Thanks Zdenek Tison and Mattias for driving this proposal! It's indeed a great improvement for Adaptive Scheduler. Sorry for the late reply, overall LGTM, I have one minor comment: These 2 configuration options were introduced since 2.0, and it's not released to users. So we can update them direc

[jira] [Created] (FLINK-35975) MongoFilterPushDownVisitorTest fails

Jiabao Sun created FLINK-35975: -- Summary: MongoFilterPushDownVisitorTest fails Key: FLINK-35975 URL: https://issues.apache.org/jira/browse/FLINK-35975 Project: Flink Issue Type: Bug Co

[jira] [Created] (FLINK-35974) PyFlink YARN per-job on Docker test failed because docker-compose command not found

Weijie Guo created FLINK-35974: -- Summary: PyFlink YARN per-job on Docker test failed because docker-compose command not found Key: FLINK-35974 URL: https://issues.apache.org/jira/browse/FLINK-35974 Proje

[DISCUSS] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs

Hi devs, I'd like to initiate a discussion about FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs[1]. FLIP-424[2] has introduced an asynchronous state architecture to mitigate I/O bottlenecks in Flink by offloading state access to separate threads from the main thread

Re: [DISCUSS] FLIP-470: Support Adaptive Broadcast Join

Hi all, Thanks for all the feedback and suggestions so far. If there are no further comments, we will open the voting thread tomorrow, Aug 6, 2024. Best, Xia Lincoln Lee 于2024年8月1日周四 22:18写道： > Hi Xia, > > Thanks for your updates! Looks good to me. > > Best, > Lincoln Lee > > > Xia Sun 于2024年

[jira] [Created] (FLINK-35973) HeartbeatManagerTest.testHeartbeatTimeout failed

Weijie Guo created FLINK-35973: -- Summary: HeartbeatManagerTest.testHeartbeatTimeout failed Key: FLINK-35973 URL: https://issues.apache.org/jira/browse/FLINK-35973 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-35972) Directly specify key and process runnable in async state execution model

Zakelly Lan created FLINK-35972: --- Summary: Directly specify key and process runnable in async state execution model Key: FLINK-35972 URL: https://issues.apache.org/jira/browse/FLINK-35972 Project: Flink