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 6e8e3d2984 Add exception for resource limit exceeded in
MultiStageOperator (#16077)
6e8e3d2984 is described below
commit 6e8e3d2984d8853b85f48552bda4fe3348cf91aa
Author: Gonzalo Ortiz Jaureguizar <[email protected]>
AuthorDate: Fri Jun 13 08:22:18 2025 +0200
Add exception for resource limit exceeded in MultiStageOperator (#16077)
---
.../org/apache/pinot/query/runtime/operator/MultiStageOperator.java | 3 +++
1 file changed, 3 insertions(+)
diff --git
a/pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/MultiStageOperator.java
b/pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/MultiStageOperator.java
index 6d62ced830..edc6de4160 100644
---
a/pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/MultiStageOperator.java
+++
b/pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/MultiStageOperator.java
@@ -41,6 +41,7 @@ import
org.apache.pinot.query.runtime.plan.MultiStageQueryStats;
import org.apache.pinot.query.runtime.plan.OpChainExecutionContext;
import org.apache.pinot.query.runtime.plan.pipeline.PipelineBreakerOperator;
import org.apache.pinot.spi.exception.EarlyTerminationException;
+import org.apache.pinot.spi.exception.QueryErrorCode;
import org.apache.pinot.spi.trace.InvocationScope;
import org.apache.pinot.spi.trace.Tracing;
import org.slf4j.Logger;
@@ -78,6 +79,8 @@ public abstract class MultiStageOperator
Tracing.ThreadAccountantOps.sampleMSE();
if (Tracing.ThreadAccountantOps.isInterrupted()) {
earlyTerminate();
+ throw
QueryErrorCode.SERVER_RESOURCE_LIMIT_EXCEEDED.asException("Resource limit
exceeded for operator: "
+ + getExplainName());
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
