This is an automated email from the ASF dual-hosted git repository. irakov pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push: new 1eccb2d IGNITE-12136 Test ClusterReadOnlyModeTest is flaky. - Fixes #6835. 1eccb2d is described below commit 1eccb2d648e42fd25f3abdf85db95dcdf36aeaea Author: Sergey Antonov <antonovserge...@gmail.com> AuthorDate: Tue Sep 3 20:54:57 2019 +0300 IGNITE-12136 Test ClusterReadOnlyModeTest is flaky. - Fixes #6835. Signed-off-by: Ivan Rakov <ira...@apache.org> --- .../ignite/internal/processors/cache/ClusterReadOnlyModeTest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/ClusterReadOnlyModeTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/ClusterReadOnlyModeTest.java index e826f73..327a3f5 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/ClusterReadOnlyModeTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/ClusterReadOnlyModeTest.java @@ -129,7 +129,7 @@ public class ClusterReadOnlyModeTest extends ClusterReadOnlyModeAbstractTest { firstPackLatch.countDown(); - readOnlyEnabled.await(5, TimeUnit.SECONDS); + assertTrue(cacheName, readOnlyEnabled.await(60, TimeUnit.SECONDS)); doLoad(streamer, 100, 1000000, manualFlush); @@ -148,13 +148,13 @@ public class ClusterReadOnlyModeTest extends ClusterReadOnlyModeAbstractTest { })); } - firstPackLatch.await(5, TimeUnit.SECONDS); + assertTrue(firstPackLatch.await(60, TimeUnit.SECONDS)); changeClusterReadOnlyMode(true); readOnlyEnabled.countDown(); - finishLatch.await(5, TimeUnit.SECONDS); + assertTrue(finishLatch.await(60, TimeUnit.SECONDS)); assertEquals("exceptions: " + eMap, cacheNames().size(), eMap.size()); @@ -181,7 +181,7 @@ public class ClusterReadOnlyModeTest extends ClusterReadOnlyModeAbstractTest { IgniteInternalFuture<?> fut = futs.get(cacheName); try { - fut.get(5, TimeUnit.SECONDS); + fut.get(15, TimeUnit.SECONDS); } catch (Exception e) { log.error("Failed to get future " + cacheName, e);