From 8eff1486bdb94ecff03f289cd368c6020b600f8e Mon Sep 17 00:00:00 2001 From: minghong Date: Tue, 17 Oct 2023 18:06:11 +0800 Subject: [PATCH] [feature](nereids)print query id with memo and physical tree (#25501) print query id with memo and physical tree when dump_nereids_memo switched on. This is used for regression test. --- .../main/java/org/apache/doris/nereids/NereidsPlanner.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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 7553817867..436ecae552 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 @@ -55,6 +55,7 @@ import org.apache.doris.planner.Planner; import org.apache.doris.planner.RuntimeFilter; import org.apache.doris.planner.ScanNode; import org.apache.doris.qe.CommonResultSet; +import org.apache.doris.qe.ConnectContext; import org.apache.doris.qe.ResultSet; import org.apache.doris.qe.ResultSetMetaData; @@ -227,7 +228,7 @@ public class NereidsPlanner extends Planner { // if chooseNthPlan failed, we could get memo to debug if (cascadesContext.getConnectContext().getSessionVariable().dumpNereidsMemo) { String memo = cascadesContext.getMemo().toString(); - LOG.info(memo); + LOG.info(ConnectContext.get().getQueryIdentifier() + "\n" + memo); } int nth = cascadesContext.getConnectContext().getSessionVariable().getNthOptimizedPlan(); @@ -236,7 +237,7 @@ public class NereidsPlanner extends Planner { physicalPlan = postProcess(physicalPlan); if (cascadesContext.getConnectContext().getSessionVariable().dumpNereidsMemo) { String tree = physicalPlan.treeString(); - LOG.info(tree); + LOG.info(ConnectContext.get().getQueryIdentifier() + "\n" + tree); } if (explainLevel == ExplainLevel.OPTIMIZED_PLAN || explainLevel == ExplainLevel.ALL_PLAN