diff --git a/fe/fe-core/src/main/java/org/apache/doris/tablefunction/MetadataGenerator.java b/fe/fe-core/src/main/java/org/apache/doris/tablefunction/MetadataGenerator.java index b96ec3ef9b9d3c..e6d479105fae9f 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/tablefunction/MetadataGenerator.java +++ b/fe/fe-core/src/main/java/org/apache/doris/tablefunction/MetadataGenerator.java @@ -43,7 +43,6 @@ import org.apache.doris.common.UserException; import org.apache.doris.common.proc.FrontendsProcNode; import org.apache.doris.common.proc.PartitionsProcDir; -import org.apache.doris.common.util.MetaLockUtils; import org.apache.doris.common.util.NetUtils; import org.apache.doris.common.util.TimeUtils; import org.apache.doris.common.util.Util; @@ -63,10 +62,8 @@ import org.apache.doris.job.common.JobType; import org.apache.doris.job.extensions.mtmv.MTMVJob; import org.apache.doris.job.task.AbstractTask; -import org.apache.doris.mtmv.BaseTableInfo; import org.apache.doris.mtmv.MTMVPartitionUtil; import org.apache.doris.mtmv.MTMVStatus; -import org.apache.doris.mtmv.MTMVUtil; import org.apache.doris.mysql.privilege.PrivPredicate; import org.apache.doris.plsql.metastore.PlsqlManager; import org.apache.doris.plsql.metastore.PlsqlProcedureKey; @@ -115,7 +112,6 @@ import java.time.LocalDateTime; import java.util.ArrayList; import java.util.Collection; -import java.util.Comparator; import java.util.Date; import java.util.List; import java.util.Map; @@ -851,25 +847,9 @@ private static TFetchSchemaTableDataResult mtmvMetadataResult(TMetadataTableRequ if (LOG.isDebugEnabled()) { LOG.debug("mv: {}", mv.toInfoString()); } - List needLocked = Lists.newArrayList(); - needLocked.add(mv); - boolean alwaysNotSync = false; - try { - for (BaseTableInfo baseTableInfo : mv.getRelation().getBaseTables()) { - TableIf baseTable = MTMVUtil.getTable(baseTableInfo); - needLocked.add(baseTable); - } - } catch (Exception e) { - alwaysNotSync = true; - } - needLocked.sort(Comparator.comparing(TableIf::getId)); - MetaLockUtils.readLockTables(needLocked); - boolean isSync; - try { - isSync = !alwaysNotSync && MTMVPartitionUtil.isMTMVSync(mv); - } finally { - MetaLockUtils.readUnlockTables(needLocked); - } + + boolean isSync = MTMVPartitionUtil.isMTMVSync(mv); + MTMVStatus mtmvStatus = mv.getStatus(); TRow trow = new TRow(); trow.addToColumnValue(new TCell().setLongVal(mv.getId()));