Re: Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests

+1 (binding) Best, Zakelly On Thu, Aug 15, 2024 at 9:02 PM Hangxiang Yu wrote: > +1 (binding) > > Thanks for driving this. > > On Thu, Aug 15, 2024 at 8:42 PM Ahmed Hamdy wrote: > > > +1 (non-binding) > > Thanks for driving. > > Best Regards > > Ahmed Hamdy > > > > > > On Wed, 14 Aug 2024 at 0

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

+1 (binding) Best, Zakelly On Wed, Aug 21, 2024 at 10:33 AM Xuyang wrote: > Hi, everyone. > > I would like to start a vote on FLIP-473: Introduce New SQL Operators Based > > on Asynchronous State APIs [1]. The discussion thread can be found here > [2]. > > The vote will be open for at least 72

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

Hi, everyone. I would like to start a vote on FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs [1]. The discussion thread can be found here [2]. The vote will be open for at least 72 hours unless there are any objections or insufficient votes. [1] https://cwiki.apache

[jira] [Created] (FLINK-36115) Allow to scan newly table DDL during incremental reading stage.

LvYanquan created FLINK-36115: - Summary: Allow to scan newly table DDL during incremental reading stage. Key: FLINK-36115 URL: https://issues.apache.org/jira/browse/FLINK-36115 Project: Flink Is

[jira] [Created] (FLINK-36114) Schema registry should block when handling existing requests

yux created FLINK-36114: --- Summary: Schema registry should block when handling existing requests Key: FLINK-36114 URL: https://issues.apache.org/jira/browse/FLINK-36114 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-36113) Condition 'transform instanceof PhysicalTransformation' is always 'false'

tiancx created FLINK-36113: -- Summary: Condition 'transform instanceof PhysicalTransformation' is always 'false' Key: FLINK-36113 URL: https://issues.apache.org/jira/browse/FLINK-36113 Project: Flink

[jira] [Created] (FLINK-36112) Add Support for CreateFlag.NO_LOCAL_WRITE in FLINK on YARN's File Creation to Manage Disk Space and Network Load in Labeled YARN Nodes

liang yu created FLINK-36112: Summary: Add Support for CreateFlag.NO_LOCAL_WRITE in FLINK on YARN's File Creation to Manage Disk Space and Network Load in Labeled YARN Nodes Key: FLINK-36112 URL: https://issues.apache

[jira] [Created] (FLINK-36111) fix: adjust MultiTableCommittableChannelComputer Topology name

MOBIN created FLINK-36111: - Summary: fix: adjust MultiTableCommittableChannelComputer Topology name Key: FLINK-36111 URL: https://issues.apache.org/jira/browse/FLINK-36111 Project: Flink Issue Type

Re: [DISCUSS] FLIP-XXX Amazon SQS Source Connector

Hi Abhisagar and Saurabh I have created the FLIP page and assigned it FLIP-477[1]. Feel free to resume with the next steps. 1- https://cwiki.apache.org/confluence/display/FLINK/FLIP-+477+Amazon+SQS+Source+Connector Best Regards Ahmed Hamdy On Tue, 20 Aug 2024 at 06:05, Abhisagar Khatri wrote:

[jira] [Created] (FLINK-36110) Periodic save points trigger continuously

Gyula Fora created FLINK-36110: -- Summary: Periodic save points trigger continuously Key: FLINK-36110 URL: https://issues.apache.org/jira/browse/FLINK-36110 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36109) Improve FlinkStateSnapshot resource labels for efficient filtering

Gyula Fora created FLINK-36109: -- Summary: Improve FlinkStateSnapshot resource labels for efficient filtering Key: FLINK-36109 URL: https://issues.apache.org/jira/browse/FLINK-36109 Project: Flink

[jira] [Created] (FLINK-36108) Wait for state download on cancellation to enforce cleanup

Piotr Nowojski created FLINK-36108: -- Summary: Wait for state download on cancellation to enforce cleanup Key: FLINK-36108 URL: https://issues.apache.org/jira/browse/FLINK-36108 Project: Flink