This is an automated email from the ASF dual-hosted git repository.
mymeiyi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 53a7c36a9e3 [fix](fe) Avoid redundant partition version fetch during
SQL cache validation (#67125)
53a7c36a9e3 is described below
commit 53a7c36a9e34e91e2c85fa8a5fadbae6b0e71e38
Author: meiyi <[email protected]>
AuthorDate: Wed Sep 2 10:01:50 2026 +0800
[fix](fe) Avoid redundant partition version fetch during SQL cache
validation (#67125)
Problem Summary: SQL cache validation fetched cloud partition versions but
discarded the result, and then used the FE partition map for the actual
existence check. So remove this version fetch to reduce an unnecessary Meta
Service RPC.
---
.../org/apache/doris/common/cache/NereidsSqlCacheManager.java | 9 ---------
1 file changed, 9 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/common/cache/NereidsSqlCacheManager.java
b/fe/fe-core/src/main/java/org/apache/doris/common/cache/NereidsSqlCacheManager.java
index bee844a9349..11914c5556d 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/common/cache/NereidsSqlCacheManager.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/common/cache/NereidsSqlCacheManager.java
@@ -81,7 +81,6 @@ import org.apache.logging.log4j.Logger;
import java.lang.reflect.Field;
import java.time.Duration;
-import java.util.Collection;
import java.util.LinkedHashSet;
import java.util.List;
import java.util.Map;
@@ -489,14 +488,6 @@ public class NereidsSqlCacheManager {
TableIf tableIf = findTableIf(env, fullTableName);
if (tableIf instanceof OlapTable) {
OlapTable olapTable = (OlapTable) tableIf;
- Collection<Long> partitionIds = scanTable.getScanPartitions();
- try {
- olapTable.getVersionInBatchForCloudMode(partitionIds);
- } catch (RpcException e) {
- LOG.warn("failed to get version in batch for table {}",
fullTableName, e);
- return IsChanged.CHANGED_AND_INVALIDATE_CACHE;
- }
-
for (Long scanPartitionId : scanTable.getScanPartitions()) {
Partition partition =
olapTable.getPartition(scanPartitionId);
// partition == null: is this partition truncated?
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
