(pinot) branch master updated: Change the logs in case of error while sending messages through GRPC (#16010)

[gortiz]

This is an automated email from the ASF dual-hosted git repository.

gortiz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git


The following commit(s) were added to refs/heads/master by this push:
     new 153c50d38e Change the logs in case of error while sending messages 
through GRPC (#16010)
153c50d38e is described below

commit 153c50d38e23bc796c448273df07c4c36ee6e03f
Author: Gonzalo Ortiz Jaureguizar <gor...@users.noreply.github.com>
AuthorDate: Fri Jun 6 12:42:58 2025 +0200

    Change the logs in case of error while sending messages through GRPC 
(#16010)
---
 .../org/apache/pinot/query/mailbox/GrpcSendingMailbox.java     | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git 
a/pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/GrpcSendingMailbox.java
 
b/pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/GrpcSendingMailbox.java
index 0ef5fed139..b7478aa65e 100644
--- 
a/pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/GrpcSendingMailbox.java
+++ 
b/pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/GrpcSendingMailbox.java
@@ -115,7 +115,12 @@ public class GrpcSendingMailbox implements SendingMailbox {
     if (_contentObserver == null) {
       _contentObserver = getContentObserver();
     }
-    processAndSend(block, serializedStats);
+    try {
+      processAndSend(block, serializedStats);
+    } catch (IOException e) {
+      LOGGER.warn("Failed to split and send mailbox", e);
+      throw e;
+    }
     if (LOGGER.isDebugEnabled()) {
       LOGGER.debug("==[GRPC SEND]== message " + block + " sent to: " + _id);
     }
@@ -132,9 +137,6 @@ public class GrpcSendingMailbox implements SendingMailbox {
         LOGGER.debug("Serialized block: {} to {} bytes", block, sizeInBytes);
       }
       _statMap.merge(MailboxSendOperator.StatKey.SERIALIZED_BYTES, 
sizeInBytes);
-    } catch (Throwable t) {
-      LOGGER.warn("Caught exception while serializing block: {}", block, t);
-      throw t;
     } finally {
       _statMap.merge(MailboxSendOperator.StatKey.SERIALIZATION_TIME_MS, 
System.currentTimeMillis() - start);
     }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org