[hotfix] Log toString of discarded message if RpcActor is not running

lightClouds917 · Feb 3, 2022 · f5504a0 · f5504a0
1 parent 2529767
commit f5504a0
Showing 1 changed file with 3 additions and 3 deletions.
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
@@ -168,13 +168,13 @@ private void handleMessage(final Object message) {
             log.info(
                     "The rpc endpoint {} has not been started yet. Discarding message {} until processing is started.",
                     rpcEndpoint.getClass().getName(),
-                    message.getClass().getName());
+                    message);
 
             sendErrorIfSender(
                     new AkkaRpcException(
                             String.format(
-                                    "Discard message, because the rpc endpoint %s has not been started yet.",
-                                    rpcEndpoint.getAddress())));
+                                    "Discard message %s, because the rpc endpoint %s has not been started yet.",
+                                    message, rpcEndpoint.getAddress())));
         }
     }