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")); + } } } }