This is an automated email from the ASF dual-hosted git repository. He-Pin pushed a commit to branch fix/endpoint-robustness-3163 in repository https://gitbox.apache.org/repos/asf/pekko.git
commit 48a5b93403e911e7130ef001e1e4db57f3d4aa90 Author: 虎鸣 <[email protected]> AuthorDate: Wed Jun 24 04:19:58 2026 +0800 fix: update log message to cover all deserialization failures Address review feedback: widen log message from "Serializer not defined" to "Could not deserialize" since the catch block now handles all NonFatal exceptions, not just missing serializer configurations. --- remote/src/main/scala/org/apache/pekko/remote/Endpoint.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/remote/src/main/scala/org/apache/pekko/remote/Endpoint.scala b/remote/src/main/scala/org/apache/pekko/remote/Endpoint.scala index 083a81428d..5031e2be1b 100644 --- a/remote/src/main/scala/org/apache/pekko/remote/Endpoint.scala +++ b/remote/src/main/scala/org/apache/pekko/remote/Endpoint.scala @@ -1177,7 +1177,7 @@ private[remote] class EndpointReader( private def logTransientSerializationError(msg: PekkoPduCodec.Message, error: Throwable): Unit = { val sm = msg.serializedMessage log.warning( - "Serializer not defined for message with serializer id [{}] and manifest [{}]. " + + "Could not deserialize message with serializer id [{}] and manifest [{}]. " + "Transient association error (association remains live). {}", sm.getSerializerId, if (sm.hasMessageManifest) sm.getMessageManifest.toStringUtf8 else "", --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
