diff --git a/redis/redis-keeper/src/main/java/com/ctrip/xpipe/redis/keeper/applier/sequence/DefaultSequenceController.java b/redis/redis-keeper/src/main/java/com/ctrip/xpipe/redis/keeper/applier/sequence/DefaultSequenceController.java
index bc0403e59..ae2b7ee63 100644
--- a/redis/redis-keeper/src/main/java/com/ctrip/xpipe/redis/keeper/applier/sequence/DefaultSequenceController.java
+++ b/redis/redis-keeper/src/main/java/com/ctrip/xpipe/redis/keeper/applier/sequence/DefaultSequenceController.java
@@ -93,6 +93,8 @@ protected void doDispose() throws Exception {
         super.doDispose();
         closeState.setClosed();
         runningCommands.clear();
+        memoryThreshold.reset();
+        concurrencyThreshold.reset();
     }
 
     @Override
diff --git a/redis/redis-keeper/src/main/java/com/ctrip/xpipe/redis/keeper/applier/threshold/ConcurrencyThreshold.java b/redis/redis-keeper/src/main/java/com/ctrip/xpipe/redis/keeper/applier/threshold/ConcurrencyThreshold.java
index df56a8827..7db33370f 100644
--- a/redis/redis-keeper/src/main/java/com/ctrip/xpipe/redis/keeper/applier/threshold/ConcurrencyThreshold.java
+++ b/redis/redis-keeper/src/main/java/com/ctrip/xpipe/redis/keeper/applier/threshold/ConcurrencyThreshold.java
@@ -19,4 +19,8 @@ public void release() {
         super.release(1);
     }
 
+    @Override
+    public void reset() {
+        super.reset();
+    }
 }
diff --git a/redis/redis-keeper/src/main/java/com/ctrip/xpipe/redis/keeper/applier/threshold/MemoryThreshold.java b/redis/redis-keeper/src/main/java/com/ctrip/xpipe/redis/keeper/applier/threshold/MemoryThreshold.java
index a0171c85c..bb417031c 100644
--- a/redis/redis-keeper/src/main/java/com/ctrip/xpipe/redis/keeper/applier/threshold/MemoryThreshold.java
+++ b/redis/redis-keeper/src/main/java/com/ctrip/xpipe/redis/keeper/applier/threshold/MemoryThreshold.java
@@ -20,4 +20,9 @@ public void tryPass(long bytes) {
     public void release(long bytes) {
         super.release(bytes);
     }
+
+    @Override
+    public void reset() {
+        super.reset();
+    }
 }