This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch opt_dict_perf
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/opt_dict_perf by this push:
new 341cb02f07 f
341cb02f07 is described below
commit 341cb02f07b225e4b65e070d79360078b4128bb7
Author: yiguolei <[email protected]>
AuthorDate: Wed Mar 15 15:09:52 2023 +0800
f
---
.../java/org/apache/doris/nereids/NereidsPlanner.java | 15 +++++++++++++++
1 file changed, 15 insertions(+)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/NereidsPlanner.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/NereidsPlanner.java
index 6a70fbbc79..89928797a5 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/nereids/NereidsPlanner.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/NereidsPlanner.java
@@ -159,15 +159,19 @@ public class NereidsPlanner extends Planner {
try (Lock lock = new Lock(plan, cascadesContext)) {
// resolve column, table and function
+ LOG.info("yyy1");
analyze();
+ LOG.info("yyy1");
if (explainLevel == ExplainLevel.ANALYZED_PLAN || explainLevel ==
ExplainLevel.ALL_PLAN) {
analyzedPlan = cascadesContext.getRewritePlan();
if (explainLevel == ExplainLevel.ANALYZED_PLAN) {
return analyzedPlan;
}
}
+ LOG.info("yyy1");
// rule-based optimize
rewrite();
+ LOG.info("yyy1");
if (explainLevel == ExplainLevel.REWRITTEN_PLAN || explainLevel ==
ExplainLevel.ALL_PLAN) {
rewrittenPlan = cascadesContext.getRewritePlan();
if (explainLevel == ExplainLevel.REWRITTEN_PLAN) {
@@ -175,11 +179,17 @@ public class NereidsPlanner extends Planner {
}
}
+ LOG.info("yyy1");
initMemo();
+ LOG.info("yyy1");
+ LOG.info("yyy1");
deriveStats();
+ LOG.info("yyy1");
+ LOG.info("yyy1");
optimize();
+ LOG.info("yyy1");
//print memo before choose plan.
//if chooseNthPlan failed, we could get memo to debug
@@ -191,8 +201,10 @@ public class NereidsPlanner extends Planner {
int nth =
ConnectContext.get().getSessionVariable().getNthOptimizedPlan();
PhysicalPlan physicalPlan = chooseNthPlan(getRoot(),
requireProperties, nth);
+ LOG.info("yyy1");
physicalPlan = postProcess(physicalPlan);
+ LOG.info("yyy1");
if (ConnectContext.get().getSessionVariable().isDumpNereidsMemo())
{
String tree = physicalPlan.treeString();
LOG.info(tree);
@@ -230,9 +242,12 @@ public class NereidsPlanner extends Planner {
}
private void deriveStats() {
+ LOG.info("yyy1");
cascadesContext.pushJob(
new DeriveStatsJob(getRoot().getLogicalExpression(),
cascadesContext.getCurrentJobContext()));
+ LOG.info("yyy1");
cascadesContext.getJobScheduler().executeJobPool(cascadesContext);
+ LOG.info("yyy1");
}
private void dpHypOptimize() {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
