Skip to content

Commit ccf2aca

Browse files
committed
fix test
1 parent ecfbe60 commit ccf2aca

File tree

1 file changed

+18
-3
lines changed

1 file changed

+18
-3
lines changed

modules/control-utility/src/test/java/org/apache/ignite/util/GridCommandHandlerCheckpointTest.java

Lines changed: 18 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -19,9 +19,12 @@
1919

2020
import java.util.Objects;
2121
import java.util.regex.Pattern;
22+
23+
import org.apache.ignite.IgniteCache;
2224
import org.apache.ignite.cluster.ClusterState;
2325
import org.apache.ignite.configuration.IgniteConfiguration;
2426
import org.apache.ignite.internal.IgniteEx;
27+
import org.apache.ignite.testframework.GridTestUtils;
2528
import org.apache.ignite.testframework.ListeningTestLogger;
2629
import org.apache.ignite.testframework.LogListener;
2730
import org.junit.Test;
@@ -67,29 +70,41 @@ public void testCheckpointPersistenceCluster() throws Exception {
6770

6871
srv.cluster().state(ClusterState.ACTIVE);
6972

73+
IgniteCache<Integer, Integer> cacheSrv = srv.getOrCreateCache(DEFAULT_CACHE_NAME);
74+
IgniteCache<Integer, Integer> cacheCli = cli.getOrCreateCache(DEFAULT_CACHE_NAME);
75+
76+
cacheSrv.put(1, 1);
77+
cacheCli.put(1, 1);
78+
7079
assertEquals(EXIT_CODE_OK, execute("--checkpoint"));
7180

7281
String out = testOut.toString();
7382
assertFalse(out.contains(cli.localNode().id().toString()));
7483
assertFalse(out.contains(Objects.toString(cli.localNode().consistentId())));
7584

7685
outputContains("Checkpoint triggered on all nodes");
77-
assertTrue(checkpointFinishedLsnr.check());
86+
assertTrue(GridTestUtils.waitForCondition(checkpointFinishedLsnr::check, 10_000));
7887

7988
testOut.reset();
8089
checkpointFinishedLsnr.reset();
8190

91+
cacheSrv.put(2, 2);
92+
cacheCli.put(2, 2);
93+
8294
assertEquals(EXIT_CODE_OK, execute("--checkpoint", "--reason", "test_reason"));
8395
outputContains("Checkpoint triggered on all nodes");
8496

85-
assertTrue(checkpointFinishedLsnr.check());
97+
assertTrue(GridTestUtils.waitForCondition(checkpointFinishedLsnr::check, 10_000));
8698
testOut.reset();
8799
checkpointFinishedLsnr.reset();
88100

101+
cacheSrv.put(3, 3);
102+
cacheCli.put(3, 3);
103+
89104
assertEquals(EXIT_CODE_OK, execute("--checkpoint", "--wait-for-finish"));
90105
outputContains("Checkpoint triggered on all nodes");
91106

92-
assertTrue(checkpointFinishedLsnr.check());
107+
assertTrue(GridTestUtils.waitForCondition(checkpointFinishedLsnr::check, 10_000));
93108
checkpointFinishedLsnr.reset();
94109
}
95110

0 commit comments

Comments
 (0)