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