Feifan Wang created FLINK-35434:
-----------------------------------
Summary: Support pass exception in StateExecutor to runtime
Key: FLINK-35434
URL: https://issues.apache.org/jira/browse/FLINK-35434
Project: Flink
Issue Type: Sub-task
Components: Runtime / State Backends
Reporter: Feifan Wang
Exception may thrown when _StateExecutor_ execute the state request , such as a
IOException. We should pass the exception to runtime then failed the job in
this situation.
_InternalStateFuture#completeExceptionally()_ will be added as [discussion
here|https://github.com/apache/flink/pull/24739#discussion_r1590633134].
And then, _ForStWriteBatchOperation_ and _ForStGeneralMultiGetOperation_ will
call this method when exception occurred.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
