diff --git a/akka-remote/src/main/scala/akka/remote/artery/Codecs.scala b/akka-remote/src/main/scala/akka/remote/artery/Codecs.scala index bfd32a6fa0..92889113b2 100644 --- a/akka-remote/src/main/scala/akka/remote/artery/Codecs.scala +++ b/akka-remote/src/main/scala/akka/remote/artery/Codecs.scala @@ -681,12 +681,12 @@ private[remote] class Deserializer( case OptionVal.Some(a) => a.remoteAddress case _ => "unknown" } - log.warning( - "Failed to deserialize message from [{}] with serializer id [{}] and manifest [{}]. {}", + log.error( + e, + "Failed to deserialize message from [{}] with serializer id [{}] and manifest [{}].", from, envelope.serializer, - envelope.classManifest, - e) + envelope.classManifest) pull(in) } finally { val buf = envelope.envelopeBuffer diff --git a/akka-remote/src/test/scala/akka/remote/artery/SerializationErrorSpec.scala b/akka-remote/src/test/scala/akka/remote/artery/SerializationErrorSpec.scala index 2722c3a782..a073058c43 100644 --- a/akka-remote/src/test/scala/akka/remote/artery/SerializationErrorSpec.scala +++ b/akka-remote/src/test/scala/akka/remote/artery/SerializationErrorSpec.scala @@ -59,7 +59,7 @@ class SerializationErrorSpec extends ArteryMultiNodeSpec(ArterySpecSupport.defau expectMsg("ping") EventFilter - .warning(pattern = """Failed to deserialize message from \[.*\] with serializer id \[4\]""", occurrences = 1) + .error(pattern = """Failed to deserialize message from \[.*\] with serializer id \[4\]""", occurrences = 1) .intercept { remoteRef ! "boom".getBytes("utf-8") }(systemB)