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

yashmayya 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 fd68b78cdb9 [Minor] Fix log for response serialization error (#17259)
fd68b78cdb9 is described below

commit fd68b78cdb985f249be7d1597af5054df1914007
Author: Xiaotian (Jackie) Jiang <[email protected]>
AuthorDate: Mon Nov 24 08:45:39 2025 -0800

    [Minor] Fix log for response serialization error (#17259)
---
 .../org/apache/pinot/core/query/scheduler/QueryScheduler.java     | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/pinot-core/src/main/java/org/apache/pinot/core/query/scheduler/QueryScheduler.java
 
b/pinot-core/src/main/java/org/apache/pinot/core/query/scheduler/QueryScheduler.java
index f123de77cf8..96a8da5a9ec 100644
--- 
a/pinot-core/src/main/java/org/apache/pinot/core/query/scheduler/QueryScheduler.java
+++ 
b/pinot-core/src/main/java/org/apache/pinot/core/query/scheduler/QueryScheduler.java
@@ -209,12 +209,12 @@ public abstract class QueryScheduler {
         if (e instanceof QueryException) {
           queryException = (QueryException) e;
           // TODO: Revisit if we should log exception here
-          LOGGER.warn("Caught QueryException while serializing response from 
response for requestId: {}, brokerId: {}",
-              requestId, brokerId, queryException);
+          LOGGER.warn("Caught QueryException while serializing response for 
requestId: {}, brokerId: {}", requestId,
+              brokerId, queryException);
         } else {
           
_serverMetrics.addMeteredGlobalValue(ServerMeter.RESPONSE_SERIALIZATION_EXCEPTIONS,
 1);
-          LOGGER.error("Caught exception while serializing response from 
response for requestId: {}, brokerId: {}",
-              requestId, brokerId, e);
+          LOGGER.error("Caught exception while serializing response for 
requestId: {}, brokerId: {}", requestId,
+              brokerId, e);
           queryException = QueryErrorCode.INTERNAL.asException("Error 
serializing response", e);
         }
       }


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to