diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/cache/CacheAnalyzer.java b/fe/fe-core/src/main/java/org/apache/doris/qe/cache/CacheAnalyzer.java index 32e287846b..ddd272542c 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/cache/CacheAnalyzer.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/cache/CacheAnalyzer.java @@ -416,8 +416,7 @@ public class CacheAnalyzer { CacheTable table = new CacheTable(); table.olapTable = olapTable; for (Partition partition : olapTable.getPartitions()) { - if (partition.getVisibleVersionTime() >= table.latestTime && - partition.getVisibleVersion() > table.latestVersion) { + if (partition.getVisibleVersionTime() >= table.latestTime) { table.latestPartitionId = partition.getId(); table.latestTime = partition.getVisibleVersionTime(); table.latestVersion = partition.getVisibleVersion();