gortiz commented on code in PR #16919:
URL: https://github.com/apache/pinot/pull/16919#discussion_r2398040406
##########
pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/InMemorySendingMailbox.java:
##########
@@ -95,6 +95,7 @@ private void sendPrivate(MseBlock block, List<DataBuffer>
serializedStats)
throw new QueryException(QueryErrorCode.EXECUTION_TIMEOUT,
String.format("Timed out adding block into mailbox: %s with
timeout: %dms", _id, timeoutMs));
case EARLY_TERMINATED:
+ case FIRST_ERROR:
Review Comment:
We should now, as I've changed the semantic of FIRST_ERROR to actually mean
something consistent. It means: The offered block is an error and no more
messages are expected.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
