Re: [DISCUSS] FLIP-408: [Umbrella] Introduce DataStream API V2

Hi,weijie Thank you very much to Weijie for proposing this series of improvements, especially the complete decoupling of user interface and implementation. This part is actually a very serious problem that disturbs downstream users in the community. I hope this problem can be completely solved in

[jira] [Created] (FLINK-34511) Flink 2.0: Deprecate legacy State options

Zakelly Lan created FLINK-34511: --- Summary: Flink 2.0: Deprecate legacy State options Key: FLINK-34511 URL: https://issues.apache.org/jira/browse/FLINK-34511 Project: Flink Issue Type:

Re: [DISCUSS] FLIP-408: [Umbrella] Introduce DataStream API V2

Hi Guowei, thanks for your reply! > Do connectors and SQL currently have similar problems? - Connectors: The APIs for FLIP-27 based source and Sink-V2 are currently in flink-core, and we will gradually move them to flink-core-api. Anyway, connector should be free of this problem. - SQL/Table:

[jira] [Created] (FLINK-34513) GroupAggregateRestoreTest.testRestore fails

Matthias Pohl created FLINK-34513: - Summary: GroupAggregateRestoreTest.testRestore fails Key: FLINK-34513 URL: https://issues.apache.org/jira/browse/FLINK-34513 Project: Flink Issue Type:

[jira] [Created] (FLINK-34514) e2e (1) times out because of an error that's most likely caused by a networking issue

Matthias Pohl created FLINK-34514: - Summary: e2e (1) times out because of an error that's most likely caused by a networking issue Key: FLINK-34514 URL: https://issues.apache.org/jira/browse/FLINK-34514

[jira] [Created] (FLINK-34510) Flink 2.0: Rename RestoreMode to RecoveryClaimMode

Zakelly Lan created FLINK-34510: --- Summary: Flink 2.0: Rename RestoreMode to RecoveryClaimMode Key: FLINK-34510 URL: https://issues.apache.org/jira/browse/FLINK-34510 Project: Flink Issue Type:

[jira] [Created] (FLINK-34512) Thrown root cause for  HandlerRequestException

Hangxiang Yu created FLINK-34512: Summary: Thrown root cause for  HandlerRequestException Key: FLINK-34512 URL: https://issues.apache.org/jira/browse/FLINK-34512 Project: Flink Issue Type:

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

Congratulations, Jiabao! Best, Ron Yun Tang 于2024年2月23日周五 19:59写道： > Congratulations, Jiabao! > > Best > Yun Tang > > From: Weihua Hu > Sent: Thursday, February 22, 2024 17:29 > To: dev@flink.apache.org > Subject: Re: [ANNOUNCE] New Apache Flink Committer -

Re: [DISCUSS]FLIP-420: Add API annotations for RocksDB StateBackend user-facing classes

@Yun Tang Thanks for the information, +1 for marking `ConfigurableRocksDBOptionsFactory` as `PublicEvolving `. Best, Yanfei Yun Tang 于2024年2月23日周五 19:54写道： > > Hi Jinzhong, > > Thanks for driving this topic, and +1 for fixing the lack of annotation. > > @Yanfei the

Re: Temporal join on rolling aggregate

+1, But I think this should be a more general requirement, that is, support for declaring watermarks in query, which can be declared for any type of source, such as table, view. Similar to databricks provided [1], this needs a FLIP. [1]

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

Congratulations, Jiabao! Best, Yuan On Mon, 26 Feb 2024 at 9:38 AM, Ron liu wrote: > Congratulations, Jiabao! > > Best, > Ron > > Yun Tang 于2024年2月23日周五 19:59写道： > > > Congratulations, Jiabao! > > > > Best > > Yun Tang > > > > From: Weihua Hu > > Sent: