You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by ja...@apache.org on 2023/07/29 02:49:48 UTC
[pinot] branch master updated: Fix the repeat planning for multi-stage query (#11215)
This is an automated email from the ASF dual-hosted git repository.
jackie 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 44434cf9d8 Fix the repeat planning for multi-stage query (#11215)
44434cf9d8 is described below
commit 44434cf9d820fc980573274a835502afe12ef4ec
Author: Xiaotian (Jackie) Jiang <17...@users.noreply.github.com>
AuthorDate: Fri Jul 28 19:49:42 2023 -0700
Fix the repeat planning for multi-stage query (#11215)
---
.../src/main/java/org/apache/pinot/query/QueryEnvironment.java | 8 +++-----
1 file changed, 3 insertions(+), 5 deletions(-)
diff --git a/pinot-query-planner/src/main/java/org/apache/pinot/query/QueryEnvironment.java b/pinot-query-planner/src/main/java/org/apache/pinot/query/QueryEnvironment.java
index 96974b9e40..b8558d3e66 100644
--- a/pinot-query-planner/src/main/java/org/apache/pinot/query/QueryEnvironment.java
+++ b/pinot-query-planner/src/main/java/org/apache/pinot/query/QueryEnvironment.java
@@ -177,8 +177,7 @@ public class QueryEnvironment {
DispatchableSubPlan dispatchableSubPlan = toDispatchableSubPlan(relRoot, plannerContext, requestId);
return new QueryPlannerResult(dispatchableSubPlan, null, dispatchableSubPlan.getTableNames());
} catch (CalciteContextException e) {
- throw new RuntimeException("Error composing query plan for '" + sqlQuery
- + "': " + e.getMessage() + "'", e);
+ throw new RuntimeException("Error composing query plan for '" + sqlQuery + "': " + e.getMessage() + "'", e);
} catch (Throwable t) {
throw new RuntimeException("Error composing query plan for: " + sqlQuery, t);
}
@@ -345,10 +344,9 @@ public class QueryEnvironment {
QueryPlan queryPlan = pinotLogicalQueryPlanner.planQuery(relRoot);
return pinotLogicalQueryPlanner.makePlan(queryPlan);
}
- private DispatchableSubPlan toDispatchableSubPlan(RelRoot relRoot, PlannerContext plannerContext,
- long requestId) {
- SubPlan subPlanRoot = toSubPlan(relRoot);
+ private DispatchableSubPlan toDispatchableSubPlan(RelRoot relRoot, PlannerContext plannerContext, long requestId) {
+ SubPlan subPlanRoot = toSubPlan(relRoot);
PinotDispatchPlanner pinotDispatchPlanner =
new PinotDispatchPlanner(plannerContext, _workerManager, requestId, _tableCache);
return pinotDispatchPlanner.createDispatchableSubPlan(subPlanRoot);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org