diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HudiDlaTable.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HudiDlaTable.java index 952d8e3311e5be..24963ec10c51cb 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HudiDlaTable.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HudiDlaTable.java @@ -79,15 +79,17 @@ public Map getAndCopyPartitionItems(Optional snapshot) throws AnalysisException { - Map partitionNameToLastModifiedMap = getOrFetchHudiSnapshotCacheValue( - snapshot).getPartitionNameToLastModifiedMap(); - return new MTMVTimestampSnapshot(partitionNameToLastModifiedMap.get(partitionName)); + // Map partitionNameToLastModifiedMap = getOrFetchHudiSnapshotCacheValue( + // snapshot).getPartitionNameToLastModifiedMap(); + // return new MTMVTimestampSnapshot(partitionNameToLastModifiedMap.get(partitionName)); + return new MTMVTimestampSnapshot(0L); } @Override public MTMVSnapshotIf getTableSnapshot(MTMVRefreshContext context, Optional snapshot) throws AnalysisException { - return new MTMVTimestampSnapshot(getOrFetchHudiSnapshotCacheValue(snapshot).getLastUpdateTimestamp()); + // return new MTMVTimestampSnapshot(getOrFetchHudiSnapshotCacheValue(snapshot).getLastUpdateTimestamp()); + return new MTMVTimestampSnapshot(0L); } @Override