diff --git a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/ha/SequenceIdGenerator.java b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/ha/SequenceIdGenerator.java
index 02b9565dd79e..4e72376f858c 100644
--- a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/ha/SequenceIdGenerator.java
+++ b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/ha/SequenceIdGenerator.java
@@ -161,23 +161,27 @@ public long getNextId(String sequenceIdName) throws SCMException {
   public void invalidateBatch() {
     lock.lock();
     try {
-      sequenceIdToBatchMap.forEach(
-          (sequenceId, batch) -> batch.nextId = batch.lastId + 1);
+      invalidateBatchInternal();
     } finally {
       lock.unlock();
     }
   }
 
+  private void invalidateBatchInternal() {
+    sequenceIdToBatchMap
+        .forEach((sequenceId, batch) -> batch.nextId = batch.lastId + 1);
+  }
+
   /**
    * Reinitialize the SequenceIdGenerator with the latest sequenceIdTable
    * during SCM reload.
    */
   public void reinitialize(Table<String, Long> sequenceIdTable)
       throws IOException {
+    LOG.info("reinitialize SequenceIdGenerator.");
     lock.lock();
     try {
-      LOG.info("reinitialize SequenceIdGenerator.");
-      invalidateBatch();
+      invalidateBatchInternal();
       stateManager.reinitialize(sequenceIdTable);
     } finally {
       lock.unlock();