Re: [PR] [FLINK-35434] Support pass exception in StateExecutor to runtime [flink]

2024-05-27 Thread via GitHub
masteryhx closed pull request #24833: [FLINK-35434] Support pass exception in StateExecutor to runtime URL: https://github.com/apache/flink/pull/24833 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

Re: [PR] [FLINK-35434] Support pass exception in StateExecutor to runtime [flink]

2024-05-24 Thread via GitHub
zoltar9264 commented on code in PR #24833: URL: https://github.com/apache/flink/pull/24833#discussion_r1613094184 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStWriteBatchOperation.java: ## @@ -75,7 +74,10 @@ public CompletableFu

Re: [PR] [FLINK-35434] Support pass exception in StateExecutor to runtime [flink]

2024-05-24 Thread via GitHub
zoltar9264 commented on code in PR #24833: URL: https://github.com/apache/flink/pull/24833#discussion_r1613094184 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStWriteBatchOperation.java: ## @@ -75,7 +74,10 @@ public CompletableFu

Re: [PR] [FLINK-35434] Support pass exception in StateExecutor to runtime [flink]

2024-05-23 Thread via GitHub
masteryhx commented on code in PR #24833: URL: https://github.com/apache/flink/pull/24833#discussion_r1612797978 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStWriteBatchOperation.java: ## @@ -75,7 +74,10 @@ public CompletableFut

Re: [PR] [FLINK-35434] Support pass exception in StateExecutor to runtime [flink]

2024-05-23 Thread via GitHub
zoltar9264 commented on code in PR #24833: URL: https://github.com/apache/flink/pull/24833#discussion_r1611657613 ## flink-core/src/main/java/org/apache/flink/core/state/StateFutureImpl.java: ## @@ -226,10 +228,19 @@ public StateFutureImpl makeNewStateFuture() { @Overrid

Re: [PR] [FLINK-35434] Support pass exception in StateExecutor to runtime [flink]

2024-05-23 Thread via GitHub
Zakelly commented on code in PR #24833: URL: https://github.com/apache/flink/pull/24833#discussion_r1611598928 ## flink-core/src/main/java/org/apache/flink/core/state/StateFutureImpl.java: ## @@ -226,10 +228,19 @@ public StateFutureImpl makeNewStateFuture() { @Override

Re: [PR] [FLINK-35434] Support pass exception in StateExecutor to runtime [flink]

2024-05-23 Thread via GitHub
zoltar9264 commented on PR #24833: URL: https://github.com/apache/flink/pull/24833#issuecomment-2126808465 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment

Re: [PR] [FLINK-35434] Support pass exception in StateExecutor to runtime [flink]

2024-05-23 Thread via GitHub
flinkbot commented on PR #24833: URL: https://github.com/apache/flink/pull/24833#issuecomment-2126742168 ## CI report: * 84c8a6aab57e02e912738beaf89678432ee06d8c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [Flink-35434] Support pass exception in StateExecutor to runtime [flink]

2024-05-23 Thread via GitHub
zoltar9264 opened a new pull request, #24833: URL: https://github.com/apache/flink/pull/24833 ## What is the purpose of the change As the title and [FLINK-35434](https://issues.apache.org/jira/browse/FLINK-35434) said, support pass exception in StateExecutor to runtime. ##