This is an automated email from the ASF dual-hosted git repository.
rongr 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 3de1c54f07 [hotfix] npe (#9639)
3de1c54f07 is described below
commit 3de1c54f072a14a981c11eb3a2cea41bec282210
Author: Rong Rong <[email protected]>
AuthorDate: Fri Oct 21 14:01:13 2022 -0700
[hotfix] npe (#9639)
Co-authored-by: Rong Rong <[email protected]>
---
.../main/java/org/apache/pinot/query/mailbox/GrpcReceivingMailbox.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/GrpcReceivingMailbox.java
b/pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/GrpcReceivingMailbox.java
index 3ce41f07b1..33662ad0ec 100644
---
a/pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/GrpcReceivingMailbox.java
+++
b/pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/GrpcReceivingMailbox.java
@@ -75,7 +75,7 @@ public class GrpcReceivingMailbox implements
ReceivingMailbox<TransferableBlock>
}
MailboxContent mailboxContent = _contentStreamObserver.poll();
_totalMsgReceived.incrementAndGet();
- return fromMailboxContent(mailboxContent);
+ return mailboxContent == null ? null : fromMailboxContent(mailboxContent);
}
@Override
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]