add debug code

apache · Jul 22, 2024 · 2398c5f · 2398c5f
1 parent 76b9c47
commit 2398c5f
Show file tree

Hide file tree

Showing 2 changed files with 30 additions and 3 deletions.
diff --git a/...main/java/org/apache/doris/nereids/rules/exploration/mv/AbstractMaterializedViewRule.java b/...main/java/org/apache/doris/nereids/rules/exploration/mv/AbstractMaterializedViewRule.java
@@ -117,7 +117,7 @@ public List<Plan> rewrite(Plan queryPlan, CascadesContext cascadesContext) {
                 continue;
             }
             // check mv plan is valid or not
-            if (!isMaterializationValid(cascadesContext, context)) {
+            if (!isMaterializationValid(queryPlan, cascadesContext, context)) {
                 continue;
             }
             // get query struct infos according to the view strut info, if valid query struct infos is empty, bail out
@@ -836,7 +836,8 @@ protected boolean checkIfRewritten(Plan plan, MaterializationContext context) {
     }
 
     // check mv plan is valid or not, this can use cache for performance
-    private boolean isMaterializationValid(CascadesContext cascadesContext, MaterializationContext context) {
+    private boolean isMaterializationValid(Plan queryPlan, CascadesContext cascadesContext,
+            MaterializationContext context) {
         long materializationId = context.generateMaterializationIdentifier().hashCode();
         Boolean cachedCheckResult = cascadesContext.getMemo().materializationHasChecked(this.getClass(),
                 materializationId);
@@ -847,6 +848,9 @@ private boolean isMaterializationValid(CascadesContext cascadesContext, Material
                 context.recordFailReason(context.getStructInfo(),
                         "View struct info is invalid", () -> String.format("view plan is %s",
                                 context.getStructInfo().getOriginalPlan().treeString()));
+                // tmp to location question
+                LOG.info(String.format("View struct info is invalid, query plan is %s, view plan is %s",
+                        queryPlan.treeString(), context.getStructInfo().getTopPlan().treeString()));
                 cascadesContext.getMemo().recordMaterializationCheckResult(this.getClass(), materializationId,
                         false);
                 return false;
@@ -858,12 +862,16 @@ private boolean isMaterializationValid(CascadesContext cascadesContext, Material
             context.recordFailReason(context.getStructInfo(),
                     "View struct info is invalid", () -> String.format("view plan is %s",
                             context.getStructInfo().getOriginalPlan().treeString()));
+            LOG.info(String.format("View struct info is invalid, query plan is %s, view plan is %s",
+                    queryPlan.treeString(), context.getStructInfo().getTopPlan().treeString()));
             return false;
         }
         if (!context.getStructInfo().isValid()) {
             context.recordFailReason(context.getStructInfo(),
                     "View struct info is invalid", () -> String.format("view plan is %s",
                             context.getStructInfo().getOriginalPlan().treeString()));
+            LOG.info(String.format("View struct info is invalid, query plan is %s, view plan is %s",
+                    queryPlan.treeString(), context.getStructInfo().getTopPlan().treeString()));
             return false;
         }
         return true;

diff --git a/regression-test/suites/nereids_rules_p0/mv/variant/variant_mv.groovy b/regression-test/suites/nereids_rules_p0/mv/variant/variant_mv.groovy
@@ -415,7 +415,26 @@ suite("variant_mv") {
     where g2.actor['id'] > 34259289 and cast(g1.actor['id'] as int) + cast(g2.repo['id'] as int) > 80000000;
     """
     order_qt_query3_0_before "${query3_0}"
-    check_mv_rewrite_success(db, mv3_0, query3_0, "mv3_0")
+
+    sql """DROP MATERIALIZED VIEW IF EXISTS mv3_0"""
+    sql"""
+        CREATE MATERIALIZED VIEW mv3_0 
+        BUILD IMMEDIATE REFRESH COMPLETE ON MANUAL
+        DISTRIBUTED BY RANDOM BUCKETS 2
+        PROPERTIES ('replication_num' = '1') 
+        AS ${mv3_0}
+        """
+
+    def job_name = getJobName(db, "mv3_0");
+    waitingMTMVTaskFinished(job_name)
+
+    def explain_memo_plan =  """explain memo plan ${query3_0}"""
+    logger.info("query3_0 explain memo plan is " + explain_memo_plan.toString())
+
+    explain {
+        sql("${query3_0}")
+        contains("mv3_0(mv3_0)")
+    }
     order_qt_query3_0_after "${query3_0}"
     sql """ DROP MATERIALIZED VIEW IF EXISTS mv3_0"""