[FLINK-34343][rpc] Use actor path when rejecting early messages

apache · Feb 5, 2024 · 839f298 · 839f298
1 parent d44e940
commit 839f298
Showing 1 changed file with 1 addition and 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
@@ -179,7 +179,7 @@ private void handleMessage(final Object message) {
  new EndpointNotStartedException(
  String.format(
  "Discard message %s, because the rpc endpoint %s has not been started yet.",
- message, rpcEndpoint.getAddress())));
+ message, getSelf().path())));
  }
  }