[jira] [Created] (FLINK-35031) Event timer firing under async execution model

Yanfei Lei created FLINK-35031: -- Summary: Event timer firing under async execution model Key: FLINK-35031 URL: https://issues.apache.org/jira/browse/FLINK-35031 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-35030) Introduce Epoch Manager for watermark under async execution

Yanfei Lei created FLINK-35030: -- Summary: Introduce Epoch Manager for watermark under async execution Key: FLINK-35030 URL: https://issues.apache.org/jira/browse/FLINK-35030 Project: Flink Issu

[jira] [Created] (FLINK-35029) Store timer in JVM heap when async execution enabled

Yanfei Lei created FLINK-35029: -- Summary: Store timer in JVM heap when async execution enabled Key: FLINK-35029 URL: https://issues.apache.org/jira/browse/FLINK-35029 Project: Flink Issue Type:

[jira] [Created] (FLINK-35028) Processing timer firing under async execution model

Yanfei Lei created FLINK-35028: -- Summary: Processing timer firing under async execution model Key: FLINK-35028 URL: https://issues.apache.org/jira/browse/FLINK-35028 Project: Flink Issue Type: S

[jira] [Created] (FLINK-35027) Implement checkpoint drain in AsyncExecutionController

Yanfei Lei created FLINK-35027: -- Summary: Implement checkpoint drain in AsyncExecutionController Key: FLINK-35027 URL: https://issues.apache.org/jira/browse/FLINK-35027 Project: Flink Issue Type

Re: [DISCUSS] FLIP-399: Flink Connector Doris

Thanks Di Wu for driving this FLIP, the updated FLIP looks good to me, +1 to start a vote. Best, Leonard > 2024年4月7日 下午12:52，wudi <676366...@qq.com.INVALID> 写道： > > Hi, > > since there are no more comments for a while, if there are no more comments > for another day, I will start a vote threa

[jira] [Created] (FLINK-35026) Introduce async-state configurations

Yanfei Lei created FLINK-35026: -- Summary: Introduce async-state configurations Key: FLINK-35026 URL: https://issues.apache.org/jira/browse/FLINK-35026 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35025) Wire AsyncExecutionController to AbstractStreamOperator

Yanfei Lei created FLINK-35025: -- Summary: Wire AsyncExecutionController to AbstractStreamOperator Key: FLINK-35025 URL: https://issues.apache.org/jira/browse/FLINK-35025 Project: Flink Issue Typ

[jira] [Created] (FLINK-35024) Implement record order preservation and buffering of AsyncExecutionController

Yanfei Lei created FLINK-35024: -- Summary: Implement record order preservation and buffering of AsyncExecutionController Key: FLINK-35024 URL: https://issues.apache.org/jira/browse/FLINK-35024 Project: Fl

Re: [DISCUSS] FLIP-399: Flink Connector Doris

Hi, since there are no more comments for a while, if there are no more comments for another day, I will start a vote thread. Thanks, di.wu > 2024年4月1日 17:52，wudi <676366...@qq.com> 写道： > > Hi, > > Gentle ping to see if there are any other concerns or things that seems > missing from the FLI

Re: [External] Inquiry Regarding Azure Pipelines

Hi Robert, Thank you for your prompt response to my previous email. I appreciate the information provided. However, I still have a few remaining questions that I hope you can assist me with. I have noticed that other PRs are now able to trigger AZP builds automatically. In my case, I have two

Re: [DISCUSS] FLIP-441: Show the JobType and remove Execution Mode on Flink WebUI

If there are no extra comments, I will start voting in three days, thank you~ Best, Rui On Thu, Mar 28, 2024 at 4:46 PM Muhammet Orazov wrote: > Hey Rui, > > Thanks for the detailed explanation and updating the FLIP! > > It is much clearer definitely, thanks for the proposal. > > Best, > Muhamm

Re: Two potential bugs in Flink ML

Hi Komal, For the first question, could you please provide a simple program that could help reproduce this exception? That could help us better find out the bugs (if any) in Flink ML. For the second question, there have been Functions implementing the IterationListener interface in Flink ML[1] an

[jira] [Created] (FLINK-35023) YARNApplicationITCase failed on Azure

Weijie Guo created FLINK-35023: -- Summary: YARNApplicationITCase failed on Azure Key: FLINK-35023 URL: https://issues.apache.org/jira/browse/FLINK-35023 Project: Flink Issue Type: Bug C

Re: [DISCUSS] FLIP-438: Amazon SQS Sink Connector

Hi Priya, Thank you for the FLIP. sqs connector would be a great addition to the flink connector aws. +1 for all the queries raised by Ahmed. Adding to Ahmed's queries, I have a few more: 1. Different connectors provide different types of fault tolerant guarantees[1]. What type of fault toleran

[jira] [Created] (FLINK-35022) Add TypeInformed Element Converter for DynamoDbSink

Ahmed Hamdy created FLINK-35022: --- Summary: Add TypeInformed Element Converter for DynamoDbSink Key: FLINK-35022 URL: https://issues.apache.org/jira/browse/FLINK-35022 Project: Flink Issue Type:

Re: [DISCUSS] FLIP-438: Amazon SQS Sink Connector

Hi Dhingra, thanks for raising the FLIP I am in favour of this addition in general. I have a couple of comments/questions on the FLIP. - I am not sure why we need to suppress warnings in the sink example in the FLIP? - You provided the sink example as it is the Public Interface, however the actual

Re: [FYI] The Azure CI for PRs is currently not triggered

Thanks all! Best regards, Weijie lorenzo affetti 于2024年4月4日周四 20:04写道： > The CI is back to normal since this morning. > Thanks to the collaboration with Robert and Mathias. > > For more information, see the issue link in Matthias message. > > > > On Thu, Apr 4, 2024, 08:23 Matthias Pohl > wr