diff --git a/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisManager.java b/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisManager.java index 63ae94e37d..7c246b4587 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisManager.java +++ b/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisManager.java @@ -936,7 +936,7 @@ public class AnalysisManager implements Writable { // Set to true means new partition loaded data public void setNewPartitionLoaded(long tblId) { TableStatsMeta statsStatus = idToTblStats.get(tblId); - if (statsStatus != null) { + if (statsStatus != null && Env.getCurrentEnv().isMaster() && !Env.isCheckpointThread()) { statsStatus.newPartitionLoaded.set(true); logCreateTableStats(statsStatus); }