From 0e8c67764c2b9424a871b601a7339bde35af119d Mon Sep 17 00:00:00 2001 From: BePPPower Date: Wed, 26 Mar 2025 15:00:36 +0800 Subject: [PATCH] fix 1 --- .../org/apache/doris/datasource/hive/HudiDlaTable.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) 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