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 index 076a4f4e8bb050..625fe7d91870ef 100644 --- 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 index 92a4fb76d49aaa..bafdd5646bed7e 100644 --- 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 {