This is an automated email from the ASF dual-hosted git repository.
ankitsultana 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 45bf79241bf [bugfix] Returning error block for OpChain initialization
errors (#17161)
45bf79241bf is described below
commit 45bf79241bfa35086e33b830ce7406835e49fdc3
Author: Shaurya Chaturvedi <[email protected]>
AuthorDate: Thu Nov 13 07:11:11 2025 -0800
[bugfix] Returning error block for OpChain initialization errors (#17161)
Co-authored-by: shauryachats <[email protected]>
---
.../org/apache/pinot/query/runtime/QueryRunner.java | 18 +++++++++---------
1 file changed, 9 insertions(+), 9 deletions(-)
diff --git
a/pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/QueryRunner.java
b/pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/QueryRunner.java
index f6f598bd48a..6e59800d60c 100644
---
a/pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/QueryRunner.java
+++
b/pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/QueryRunner.java
@@ -288,16 +288,16 @@ public class QueryRunner {
OpChainExecutionContext executionContext =
OpChainExecutionContext.fromQueryContext(_mailboxService,
opChainMetadata, stageMetadata, workerMetadata,
pipelineBreakerResult, _sendStats.getAsBoolean());
- OpChain opChain;
- if (workerMetadata.isLeafStageWorker()) {
- Map<String, String> rlsFilters =
RlsUtils.extractRlsFilters(requestMetadata);
- opChain =
- ServerPlanRequestUtils.compileLeafStage(executionContext, stagePlan,
_leafQueryExecutor, _executorService,
- rlsFilters);
- } else {
- opChain = PlanNodeToOpChain.convert(stagePlan.getRootNode(),
executionContext);
- }
try {
+ OpChain opChain;
+ if (workerMetadata.isLeafStageWorker()) {
+ Map<String, String> rlsFilters =
RlsUtils.extractRlsFilters(requestMetadata);
+ opChain =
+ ServerPlanRequestUtils.compileLeafStage(executionContext,
stagePlan, _leafQueryExecutor, _executorService,
+ rlsFilters);
+ } else {
+ opChain = PlanNodeToOpChain.convert(stagePlan.getRootNode(),
executionContext);
+ }
// This can fail if the executor rejects the task.
_opChainScheduler.register(opChain);
} catch (RuntimeException e) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
