This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from edb3000 [FLINK-22443][streaming-java] Fix overflow in
MultipleInputSelectionHandler
add 09cd685 [FLINK-23202] Introduce marker interface to filter out Flink
related RPC messages
add c47d8b9 [FLINK-23202][rpc] Fail rpc requests for unreachable
recipients eagerly
add 5e78856 [hotfix] Deduplicate logic to build rpc method string
add 63de5d9 [FLINK-23202][rpc] Fail with
AkkaRecipientUnreachableException if local actor has terminated
add ccf3617 [hotfix][test] Replace junit.Assert.assertThat with
hamcrest.MatcherAssert.assertThat in AkkaRpcServiceTest
add a1d1c5c [hotfix][test] Replace junit.Assert.assertThat with
hamcrest.MatcherAssert.assertThat in RemoteAkkaRpcServiceTest
No new revisions were added by this update.
Summary of changes:
.../runtime/rpc/akka/AkkaInvocationHandler.java | 47 ++++++++++++---
.../flink/runtime/rpc/akka/AkkaRpcService.java | 8 +++
.../runtime/rpc/akka/AkkaRpcServiceUtils.java | 4 ++
.../flink/runtime/rpc/akka/DeadLettersActor.java | 70 ++++++++++++++++++++++
.../runtime/rpc/akka/AkkaActorSystemTest.java | 33 ++++++++++
.../flink/runtime/rpc/akka/AkkaRpcServiceTest.java | 28 ++++++++-
.../runtime/rpc/akka/RemoteAkkaRpcActorTest.java | 65 +++++++++++++++++++-
.../src/test/resources/log4j2-test.properties | 0
...ion.java => RecipientUnreachableException.java} | 26 ++++----
.../flink/runtime/rpc/messages/CallAsync.java | 2 +-
.../flink/runtime/rpc/messages/FencedMessage.java | 2 +-
.../rpc/messages/HandshakeSuccessMessage.java | 2 +-
.../runtime/rpc/messages/LocalRpcInvocation.java | 21 +++----
.../{HandshakeSuccessMessage.java => Message.java} | 8 +--
.../rpc/messages/RemoteHandshakeMessage.java | 2 +-
.../runtime/rpc/messages/RemoteRpcInvocation.java | 42 ++++++++-----
.../flink/runtime/rpc/messages/RpcInvocation.java | 25 +++++++-
.../flink/runtime/rpc/messages/RunAsync.java | 2 +-
.../runtime/rpc/messages/UnfencedMessage.java | 2 +-
.../FlinkUserCodeClassLoadersTest.java | 1 +
...tractTaskManagerProcessFailureRecoveryTest.java | 2 -
...skManagerProcessFailureBatchRecoveryITCase.java | 2 +-
22 files changed, 326 insertions(+), 68 deletions(-)
create mode 100644
flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/DeadLettersActor.java
copy {flink-yarn =>
flink-rpc/flink-rpc-akka}/src/test/resources/log4j2-test.properties (100%)
copy
flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/rpc/exceptions/{RpcRuntimeException.java
=> RecipientUnreachableException.java} (51%)
copy
flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/rpc/messages/{HandshakeSuccessMessage.java
=> Message.java} (85%)
