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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
