diff --git a/jraft-core/src/main/java/com/alipay/sofa/jraft/core/FSMCallerImpl.java b/jraft-core/src/main/java/com/alipay/sofa/jraft/core/FSMCallerImpl.java index e502458f1..bd63a1f8e 100644 --- a/jraft-core/src/main/java/com/alipay/sofa/jraft/core/FSMCallerImpl.java +++ b/jraft-core/src/main/java/com/alipay/sofa/jraft/core/FSMCallerImpl.java @@ -233,7 +233,6 @@ public synchronized void shutdown() { task.shutdownLatch = latch; })); } - doShutdown(); } @Override @@ -450,6 +449,7 @@ private long runApplyTask(final ApplyTask task, long maxCommittedIndex, final bo case SHUTDOWN: this.currTask = TaskType.SHUTDOWN; shutdown = task.shutdownLatch; + doShutdown(); break; case FLUSH: this.currTask = TaskType.FLUSH;