Fix epoch truncate (#9942)

LittleBoy18 · web-flow · commit 5132258db946 · 2025-12-24T09:31:42.000+08:00
diff --git a/store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAClient.java b/store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAClient.java
@@ -463,8 +463,11 @@ private boolean doTruncate(List<EpochEntry> masterEpochEntries, long masterEndOf
                 LOGGER.error("Failed to truncate slave log to {}", truncateOffset);
                 return false;
             }
-            this.epochCache.truncateSuffixByOffset(truncateOffset);
-            LOGGER.info("Truncate slave log to {} success, change to transfer state", truncateOffset);
+            final long maxPhyOffset = this.messageStore.getMaxPhyOffset();
+            if (truncateOffset < maxPhyOffset) {
+                this.epochCache.truncateSuffixByOffset(truncateOffset);
+                LOGGER.info("Truncate slave log to {} success, change to transfer state", truncateOffset);
+            }
             changeCurrentState(HAConnectionState.TRANSFER);
             this.currentReportedOffset = truncateOffset;
         }

Original file line number	Diff line number	Diff line change
`@@ -463,8 +463,11 @@ private boolean doTruncate(List<EpochEntry> masterEpochEntries, long masterEndOf`
`463`	`463`	`LOGGER.error("Failed to truncate slave log to {}", truncateOffset);`
`464`	`464`	`return false;`
`465`	`465`	`}`
`466`		`- this.epochCache.truncateSuffixByOffset(truncateOffset);`
`467`		`- LOGGER.info("Truncate slave log to {} success, change to transfer state", truncateOffset);`
	`466`	`+ final long maxPhyOffset = this.messageStore.getMaxPhyOffset();`
	`467`	`+ if (truncateOffset < maxPhyOffset) {`
	`468`	`+ this.epochCache.truncateSuffixByOffset(truncateOffset);`
	`469`	`+ LOGGER.info("Truncate slave log to {} success, change to transfer state", truncateOffset);`
	`470`	`+ }`
`468`	`471`	`changeCurrentState(HAConnectionState.TRANSFER);`
`469`	`472`	`this.currentReportedOffset = truncateOffset;`
`470`	`473`	`}`