fredia commented on code in PR #24698:
URL: https://github.com/apache/flink/pull/24698#discussion_r1590687424
##########
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AbstractAsyncStateStreamOperator.java:
##########
@@ -78,13 +81,18 @@ public void setup(
this.asyncExecutionController =
new AsyncExecutionController(
mailboxExecutor,
+ this::handleStateCallbackException,
null,
maxParallelism,
asyncBufferSize,
asyncBufferTimeout,
inFlightRecordsLimit);
}
+ private void handleStateCallbackException(String message, Throwable
exception) {
Review Comment:
Currently `StreamTask.asyncExceptionHandler::handleAsyncException` is used
to handle the exceptions thrown by processing timer, here I tend to separate
these two types of exceptions, so `StateCallbackException` is introduced here.
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
