(flink) branch release-1.17 updated: [FLINK-34343][rpc] Use actor path when rejecting early messages

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch release-1.17
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.17 by this push:
     new 3f22b6363e6 [FLINK-34343][rpc] Use actor path when rejecting early 
messages
3f22b6363e6 is described below

commit 3f22b6363e6cad4352821f42907ec8a2a181e675
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Sat Feb 3 11:20:08 2024 +0100

    [FLINK-34343][rpc] Use actor path when rejecting early messages
---
 .../src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActor.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActor.java
 
b/flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActor.java
index 8029956bbd9..59d30e16564 100644
--- 
a/flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActor.java
+++ 
b/flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActor.java
@@ -179,7 +179,7 @@ class AkkaRpcActor<T extends RpcEndpoint & RpcGateway> 
extends AbstractActor {
                     new EndpointNotStartedException(
                             String.format(
                                     "Discard message %s, because the rpc 
endpoint %s has not been started yet.",
-                                    message, rpcEndpoint.getAddress())));
+                                    message, getSelf().path())));
         }
     }