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


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

commit 839f298c3838f2f4981e271554b82fae770747d8
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())));
         }
     }