From 81541fac44c3b8a614b5b52f3cddbe04c47f83ab Mon Sep 17 00:00:00 2001
From: minghong <englefly@gmail.com>
Date: Wed, 23 Oct 2024 10:25:33 +0800
Subject: [PATCH] fix null

---
 .../apache/doris/nereids/NereidsPlanner.java  | 31 +++++++------------
 .../doris/nereids/StatementContext.java       |  6 ++--
 .../doris/nereids/stats/StatsCalculator.java  |  5 +--
 3 files changed, 18 insertions(+), 24 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 f37f112c0c14704..0a6c1e298ff9b06 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
@@ -269,7 +269,7 @@ private Plan planWithoutLock(
                     .collectToList(LogicalOlapScan.class::isInstance);
             Optional<String> disableJoinReorderReason = StatsCalculator
                     .disableJoinReorderIfStatsInvalid(scans, cascadesContext);
-            statementContext.setDisableJoinReorderReason(disableJoinReorderReason);
+            disableJoinReorderReason.ifPresent(statementContext::setDisableJoinReorderReason);
         }
 
         optimize();
@@ -578,13 +578,6 @@ public String getHintExplainString(List<Hint> hints) {
     public String getExplainString(ExplainOptions explainOptions) {
         ExplainLevel explainLevel = getExplainLevel(explainOptions);
         String plan = "";
-        String mvSummary = "";
-        if (this.getPhysicalPlan() != null && cascadesContext != null) {
-            mvSummary = cascadesContext.getMaterializationContexts().isEmpty() ? "" :
-                    "\n\n========== MATERIALIZATIONS ==========\n"
-                            + MaterializationContext.toSummaryString(cascadesContext.getMaterializationContexts(),
-                            this.getPhysicalPlan());
-        }
         switch (explainLevel) {
             case PARSED_PLAN:
                 plan = parsedPlan.treeString();
@@ -637,23 +630,23 @@ public String getExplainString(ExplainOptions explainOptions) {
                             + getTimeMetricString(SummaryProfile::getPrettyNereidsDistributeTime) + " ==========\n";
                     plan += DistributedPlan.toString(Lists.newArrayList(distributedPlans.values())) + "\n\n";
                 }
-                plan += mvSummary;
                 break;
             default:
                 plan = super.getExplainString(explainOptions);
-                plan += mvSummary;
-                plan += "\n\n\n========== STATISTICS ==========\n";
-                if (statementContext != null) {
-                    if (statementContext.isHasUnknownColStats()) {
-                        plan += "planed with unknown column statistics\n";
-                    }
-                }
         }
-
+        if (this.getPhysicalPlan() != null && cascadesContext != null) {
+            plan += cascadesContext.getMaterializationContexts().isEmpty() ? "" :
+                    "\n\n========== MATERIALIZATIONS ==========\n"
+                            + MaterializationContext.toSummaryString(cascadesContext.getMaterializationContexts(),
+                            this.getPhysicalPlan());
+        }
         if (statementContext != null) {
+            if (statementContext.isHasUnknownColStats()) {
+                plan += "planed with unknown column statistics\n";
+            }
             if (statementContext.getDisableJoinReorderReason().isPresent()) {
-                plan += "\n\n\n========== DISABLE JOIN REORDER ==========\n";
-                plan += statementContext.getDisableJoinReorderReason().get();
+                plan += "\ndisable join reorder reason\n";
+                plan += statementContext.getDisableJoinReorderReason().get() + "\n";
             }
             if (!statementContext.getHints().isEmpty()) {
                 String hint = getHintExplainString(statementContext.getHints());
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/StatementContext.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/StatementContext.java
index 64088a9a2de20f1..ed64864da5079fb 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/nereids/StatementContext.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/StatementContext.java
@@ -169,7 +169,7 @@ public class StatementContext implements Closeable {
 
     private List<PlannerHook> plannerHooks = new ArrayList<>();
 
-    private Optional<String> disableJoinReorderReason;
+    private String disableJoinReorderReason;
 
     public StatementContext() {
         this(ConnectContext.get(), null, 0);
@@ -562,10 +562,10 @@ public TableId getTableId(TableIf tableIf) {
     }
 
     public Optional<String> getDisableJoinReorderReason() {
-        return disableJoinReorderReason;
+        return Optional.ofNullable(disableJoinReorderReason);
     }
 
-    public void setDisableJoinReorderReason(Optional<String> disableJoinReorderReason) {
+    public void setDisableJoinReorderReason(String disableJoinReorderReason) {
         this.disableJoinReorderReason = disableJoinReorderReason;
     }
 }
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/stats/StatsCalculator.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/stats/StatsCalculator.java
index cb0545926b10e86..e3f385f2871f6b7 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/nereids/stats/StatsCalculator.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/stats/StatsCalculator.java
@@ -221,17 +221,18 @@ public static Optional<String> disableJoinReorderIfStatsInvalid(List<LogicalOlap
             CascadesContext context) {
         StatsCalculator calculator = new StatsCalculator(context);
         if (ConnectContext.get() == null) {
-            // ut
+            // ut case
             return Optional.empty();
         }
         for (LogicalOlapScan scan : scans) {
             double rowCount = calculator.getOlapTableRowCount(scan);
-            // analyzed rowCount may be zero, but BE-reported rowCount could be positive.
+            // row count not available
             if (rowCount == -1) {
                 LOG.info("disable join reorder since row count not available: "
                         + scan.getTable().getNameWithFullQualifiers());
                 return Optional.of("table[" + scan.getTable().getName() + "] row count is invalid");
             }
+            // ndv abnormal
             Optional<String> reason = calculator.checkNdvValidation(scan, rowCount);
             if (reason.isPresent()) {
                 try {