This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.1 by this push:
new 8e7c5b88770 branch-4.1: [fix](fe) Avoid redundant partition version
fetch during SQL cache validation #67125 (#67415)
8e7c5b88770 is described below
commit 8e7c5b887705727cba121d2badedc0d2ab2c4add
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sun Sep 6 06:02:27 2026 +0800
branch-4.1: [fix](fe) Avoid redundant partition version fetch during SQL
cache validation #67125 (#67415)
Cherry-picked from #67125
Co-authored-by: meiyi <[email protected]>
---
.../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 fe8f01b7254..1f77f1fc29b 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;
@@ -488,14 +487,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]
