commit e9d14a684a54cadc0d6feca2b8aae08e7152a705
author Marco Jorge <marco.jorge@outsystems.com> Thu Dec 23 12:17:02 2021 -0500
committer NobiGo <nobigogle@gmail.com> Tue Jan 04 09:48:32 2022 +0800
tree 1b245527e6ed6c73b284d8e2f20942355e8f841a
parent fe27e504666f1a6bf0fca87745d96a76307b26b2

[CALCITE-4962] Protobuf debug does not show request/response type

core/src/main/java/org/apache/calcite/avatica/remote/ProtobufTranslationImpl.java

diff --git a/core/src/main/java/org/apache/calcite/avatica/remote/ProtobufTranslationImpl.java b/core/src/main/java/org/apache/calcite/avatica/remote/ProtobufTranslationImpl.java
index eb616a2..7686223 100644
--- a/core/src/main/java/org/apache/calcite/avatica/remote/ProtobufTranslationImpl.java
+++ b/core/src/main/java/org/apache/calcite/avatica/remote/ProtobufTranslationImpl.java
@@ -105,7 +105,11 @@
       // This should already be an aliased CodedInputStream from the WireMessage parsing.
       Message msg = parser.parseFrom(serializedMessage.newCodedInput());
       if (LOG.isTraceEnabled()) {
-        LOG.trace("Deserialized request '{}'", TextFormat.shortDebugString(msg));
+        LOG.trace(
+            "Deserialized {} '{}'",
+            msg.getClass().getSimpleName(),
+            TextFormat.shortDebugString(msg)
+        );
       }
       return impl.deserialize(msg);
     }
@@ -129,7 +133,11 @@
         InvalidProtocolBufferException {
       Message msg = parser.parseFrom(serializedMessage);
       if (LOG.isTraceEnabled()) {
-        LOG.trace("Deserialized response '{}'", TextFormat.shortDebugString(msg));
+        LOG.trace(
+            "Deserialized {} '{}'",
+            msg.getClass().getSimpleName(),
+            TextFormat.shortDebugString(msg)
+        );
       }
       return impl.deserialize(msg);
     }
@@ -348,7 +356,11 @@
       Message responseMsg = response.serialize();
       // Serialization of the response may be large
       if (LOG.isTraceEnabled()) {
-        LOG.trace("Serializing response '{}'", TextFormat.shortDebugString(responseMsg));
+        LOG.trace(
+            "Serializing {} '{}'",
+            responseMsg.getClass().getSimpleName(),
+            TextFormat.shortDebugString(responseMsg)
+        );
       }
       serializeMessage(out, responseMsg);
       return out.toArray();
@@ -364,7 +376,11 @@
       Message requestMsg = request.serialize();
       // Serialization of the request may be large
       if (LOG.isTraceEnabled()) {
-        LOG.trace("Serializing request '{}'", TextFormat.shortDebugString(requestMsg));
+        LOG.trace(
+            "Serializing {} '{}'",
+            requestMsg.getClass().getSimpleName(),
+            TextFormat.shortDebugString(requestMsg)
+        );
       }
       serializeMessage(out, requestMsg);
       return out.toArray();