diff --git a/jraft-core/src/test/java/com/alipay/sofa/jraft/core/NodeTest.java b/jraft-core/src/test/java/com/alipay/sofa/jraft/core/NodeTest.java
index 213bb10d0..9cc9cf1bb 100644
--- a/jraft-core/src/test/java/com/alipay/sofa/jraft/core/NodeTest.java
+++ b/jraft-core/src/test/java/com/alipay/sofa/jraft/core/NodeTest.java
@@ -30,6 +30,7 @@
 import java.util.concurrent.Future;
 import java.util.concurrent.ThreadLocalRandom;
 import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.atomic.AtomicInteger;
 
@@ -3518,9 +3519,13 @@ public void testChangePeersChaosApplyTasks() throws Exception {
         for (final ChangeArg arg : args) {
             arg.stop = true;
         }
-        for (final Future<?> future : futures) {
-            future.get();
-        }
+		for (final Future<?> future : futures) {
+			try {
+				future.get(20, TimeUnit.SECONDS);
+			} catch (TimeoutException e) {
+				LOG.warn("Timeout while waiting for future completion in testChangePeersChaosApplyTasks", e);
+			}
+		}
 
         cluster.waitLeader();
         final SynchronizedClosure done = new SynchronizedClosure();
diff --git a/jraft-extension/java-log-storage-impl/src/test/java/com/alipay/sofa/jraft/core/NodeTest.java b/jraft-extension/java-log-storage-impl/src/test/java/com/alipay/sofa/jraft/core/NodeTest.java
index fb7bec9e4..29bed7235 100644
--- a/jraft-extension/java-log-storage-impl/src/test/java/com/alipay/sofa/jraft/core/NodeTest.java
+++ b/jraft-extension/java-log-storage-impl/src/test/java/com/alipay/sofa/jraft/core/NodeTest.java
@@ -3407,13 +3407,13 @@ public void testChangePeersChaosApplyTasks() throws Exception {
         for (final ChangeArg arg : args) {
             arg.stop = true;
         }
-	for (final Future<?> future : futures) {
-		try {
-			future.get(20, TimeUnit.SECONDS);
-		} catch (TimeoutException e) {
-			// ignore
+		for (final Future<?> future : futures) {
+			try {
+				future.get(20, TimeUnit.SECONDS);
+			} catch (TimeoutException e) {
+				LOG.warn("Future waiting exceeded the timeout limit.", e);
+			}
 		}
-	}
 
         cluster.waitLeader();
         final SynchronizedClosure done = new SynchronizedClosure();
diff --git a/jraft-rheakv/rheakv-core/src/test/java/com/alipay/sofa/jraft/rhea/chaos/AbstractChaosTest.java b/jraft-rheakv/rheakv-core/src/test/java/com/alipay/sofa/jraft/rhea/chaos/AbstractChaosTest.java
index fc8064b69..1f43927b9 100644
--- a/jraft-rheakv/rheakv-core/src/test/java/com/alipay/sofa/jraft/rhea/chaos/AbstractChaosTest.java
+++ b/jraft-rheakv/rheakv-core/src/test/java/com/alipay/sofa/jraft/rhea/chaos/AbstractChaosTest.java
@@ -234,7 +234,11 @@ private void chaosSplittingCheckData(final ChaosTestCluster cluster) {
         // Randomly select a client to verify data consistency
         for (int i = 0; i < LOOP_1; i++) {
             for (int j = 0; j < LOOP_2; j++) {
-                Assert.assertArrayEquals(VALUE, cluster.getRandomStore().bGet(i + "_split_test_" + j));
+                try {
+                    Assert.assertArrayEquals(VALUE, cluster.getRandomStore().bGet(i + "_split_test_" + j));
+                } catch (Exception e) {
+                    Assert.assertTrue(e.getMessage().contains("region split or merge happened"));
+                }
             }
         }
     }