tillrohrmann opened a new pull request #16342: URL: https://github.com/apache/flink/pull/16342
This PR adds support for failing RPC result futures eagerly if the recipient turns out to be unreachable (e.g. terminated or remote ActorSystem is unreachable). This allows to react to failure situations earlier. The PR contains the following main commits: #### 74dc9a1: Introduce marker interface to filter out Flink related RPC messages The marker interface rpc.messages.Message identifies all Flink related RPC messages. This can be used to filter for these messages and to trigger specific actions. #### da79d62: Fail rpc requests for unreachable recipients eagerly This commit adds the DeadLettersActor that monitor Akka's dead letter mailbox. Whenever a Flink Message is received if sends a failure to the sender to notify the sender about the unreachability of the recipient. That way it is possible to eagerly fail the result futures, and not having to wait on the rpc timeout. #### fe6bdb0: Fail with AkkaRecipientUnreachableException if local actor has terminated This commit replaces the AskTimeoutException with an AkkaRecipientUnreachableException if the local actor has already terminated. This works by looking at the exception message. This ensures that we respond with the right exception if the local actor is unreachable. -- 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]
