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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
