[ISSUE apache#5413] Modify AutoSwitchHAClient currentReceivedEpoch at…

…tribute long type to int
mxsm · Oct 27, 2022 · 88c6b8e · 88c6b8e
1 parent 4ba8aa2
commit 88c6b8e
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -92,7 +92,7 @@ public class AutoSwitchHAClient extends ServiceThread implements HAClient {
     /**
      * Current epoch
      */
-    private volatile long currentReceivedEpoch;
+    private volatile int currentReceivedEpoch;
 
     public AutoSwitchHAClient(AutoSwitchHAService haService, DefaultMessageStore defaultMessageStore,
         EpochFileCache epochCache) throws IOException {