Re: [PR] [FLINK-35046][state] Introduce AsyncKeyedStateBackend supporting to create StateExecutor [flink]

2024-04-16 Thread via GitHub
masteryhx closed pull request #24663: [FLINK-35046][state] Introduce AsyncKeyedStateBackend supporting to create StateExecutor URL: https://github.com/apache/flink/pull/24663 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

Re: [PR] [FLINK-35046][state] Introduce AsyncKeyedStateBackend supporting to create StateExecutor [flink]

2024-04-15 Thread via GitHub
Zakelly commented on code in PR #24663: URL: https://github.com/apache/flink/pull/24663#discussion_r1566625619 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/AsyncKeyedStateBackend.java: ## @@ -0,0 +1,38 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

Re: [PR] [FLINK-35046][state] Introduce AsyncKeyedStateBackend supporting to create StateExecutor [flink]

2024-04-15 Thread via GitHub
masteryhx commented on code in PR #24663: URL: https://github.com/apache/flink/pull/24663#discussion_r1565377484 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackend.java: ## @@ -104,6 +104,25 @@ default String getName() {

Re: [PR] [FLINK-35046][state] Introduce AsyncKeyedStateBackend supporting to create StateExecutor [flink]

2024-04-14 Thread via GitHub
Zakelly commented on code in PR #24663: URL: https://github.com/apache/flink/pull/24663#discussion_r1565158902 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackend.java: ## @@ -104,6 +104,25 @@ default String getName() {

Re: [PR] [FLINK-35046][state] Introduce AsyncKeyedStateBackend supporting to create StateExecutor [flink]

2024-04-14 Thread via GitHub
flinkbot commented on PR #24663: URL: https://github.com/apache/flink/pull/24663#issuecomment-2054586620 ## CI report: * b551d919ce3a63501e9ebc6f8769bd56f0c74d0c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-35046][state] Introduce AsyncKeyedStateBackend supporting to create StateExecutor [flink]

2024-04-14 Thread via GitHub
masteryhx opened a new pull request, #24663: URL: https://github.com/apache/flink/pull/24663 ## What is the purpose of the change Introduce AsyncKeyedStateBackend which supports to create StateExecutor ## Brief change log - Introduce a new interface called