diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/Catalog.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/Catalog.java index a670dd2aebf67b..80b6defca64710 100755 --- a/fe/fe-core/src/main/java/org/apache/doris/catalog/Catalog.java +++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/Catalog.java @@ -4990,7 +4990,8 @@ public HashMap getPartitionIdToStorageMediumMap() { if (dataProperty.getStorageMedium() == TStorageMedium.SSD && dataProperty.getCooldownTimeMs() < currentTimeMs) { // expire. change to HDD. - partitionInfo.setDataProperty(partition.getId(), new DataProperty(TStorageMedium.HDD)); + DataProperty hddProp = new DataProperty(TStorageMedium.HDD); + partitionInfo.setDataProperty(partition.getId(), hddProp); storageMediumMap.put(partitionId, TStorageMedium.HDD); LOG.debug("partition[{}-{}-{}] storage medium changed from SSD to HDD", dbId, tableId, partitionId); @@ -4999,7 +5000,7 @@ public HashMap getPartitionIdToStorageMediumMap() { ModifyPartitionInfo info = new ModifyPartitionInfo(db.getId(), olapTable.getId(), partition.getId(), - DataProperty.DEFAULT_DATA_PROPERTY, + hddProp, ReplicaAllocation.NOT_SET, partitionInfo.getIsInMemory(partition.getId())); editLog.logModifyPartition(info);