[opt](Nereids) avoid lock failed if async mv has invalid base info (#…

…47771) ### What problem does this PR solve? Problem Summary: sometimes, after upgrade, async mv may has invalid base table info. when do lock before plan, we should skip these infos to avoid lock failed.
apache · Feb 13, 2025 · 11bb112 · 11bb112
1 parent 86e1378
commit 11bb112
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 3 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/mtmv/BaseTableInfo.java b/fe/fe-core/src/main/java/org/apache/doris/mtmv/BaseTableInfo.java
@@ -122,6 +122,10 @@ public boolean isInternalTable() {
         }
     }
 
+    public boolean isValid() {
+        return ctlName != null && dbName != null && tableName != null;
+    }
+
     @Override
     public boolean equals(Object o) {
         if (this == o) {

diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/CollectRelation.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/CollectRelation.java
@@ -207,15 +207,18 @@ private void collectMTMVCandidates(TableIf table, CascadesContext cascadesContex
                 mtmv.readMvLock();
                 try {
                     for (BaseTableInfo baseTableInfo : mtmv.getRelation().getBaseTables()) {
+                        if (!baseTableInfo.isValid()) {
+                            continue;
+                        }
                         if (LOG.isDebugEnabled()) {
-                            LOG.info("mtmv {} related base table include {}", new BaseTableInfo(mtmv), baseTableInfo);
+                            LOG.debug("mtmv {} related base table include {}", new BaseTableInfo(mtmv), baseTableInfo);
                         }
                         try {
                             cascadesContext.getStatementContext().getAndCacheTable(baseTableInfo.toList(),
                                     TableFrom.MTMV);
                         } catch (AnalysisException exception) {
-                            LOG.warn("mtmv related base table get err, related table is "
-                                            + baseTableInfo.toList(), exception);
+                            LOG.warn("mtmv related base table get err, related table is {}",
+                                    baseTableInfo.toList(), exception);
                         }
                     }
                 } finally {