diff --git a/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreService.java b/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreService.java
index 75c61dcb382..94389a5c054 100644
--- a/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreService.java
+++ b/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreService.java
@@ -341,7 +341,7 @@ public void destroyExpiredFile(long expireTimestamp) {
         readWriteLock.writeLock().lock();
         try {
             timeStoreTable.entrySet().removeIf(entry ->
-                entry.getKey() < expireTimestamp &&
+                entry.getValue().getEndTimestamp() <= expireTimestamp &&
                     IndexFile.IndexStatusEnum.UPLOAD.equals(entry.getValue().getFileStatus()));
             flatAppendFile.destroyExpiredFile(expireTimestamp);
         } finally {