(flink) branch release-1.18 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.18
in repository https://gitbox.apache.org/repos/asf/flink.git


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

commit ee9945cd785577d0f68092823b71abbb53d127f8
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/pekko/PekkoRpcActor.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/pekko/PekkoRpcActor.java
 
b/flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/pekko/PekkoRpcActor.java
index f3724fba0e5..dc4e342f35a 100644
--- 
a/flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/pekko/PekkoRpcActor.java
+++ 
b/flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/pekko/PekkoRpcActor.java
@@ -179,7 +179,7 @@ class PekkoRpcActor<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())));
         }
     }