Repository: ignite Updated Branches: refs/heads/ignite-9720 fb639a0ba -> a092939ee
IGNITE-9720 WA for test hang Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/a092939e Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/a092939e Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/a092939e Branch: refs/heads/ignite-9720 Commit: a092939ee158a3e8e8b6f9e1e42018c7ae305836 Parents: fb639a0 Author: Alexey Goncharuk <alexey.goncha...@gmail.com> Authored: Thu Nov 29 19:44:18 2018 +0300 Committer: Alexey Goncharuk <alexey.goncha...@gmail.com> Committed: Thu Nov 29 19:44:18 2018 +0300 ---------------------------------------------------------------------- .../continuous/CacheContinuousQueryFailoverAbstractSelfTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/a092939e/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractSelfTest.java index e7c2261..7cf94e6 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractSelfTest.java @@ -1940,7 +1940,7 @@ public abstract class CacheContinuousQueryFailoverAbstractSelfTest extends GridC IgniteInternalFuture<?> restartFut = GridTestUtils.runAsync(new Callable<Void>() { @Override public Void call() throws Exception { try { - while (!stop.get() && !err) { + while (!stop.get() && !err && !Thread.currentThread().isInterrupted()) { final int idx = rnd.nextInt(SRV_NODES); log.info("Stop node: " + idx); @@ -2044,7 +2044,7 @@ public abstract class CacheContinuousQueryFailoverAbstractSelfTest extends GridC log.error("Thread id: " + threadId); - while (System.currentTimeMillis() < stopTime && !stop.get() && !err) { + while (System.currentTimeMillis() < stopTime && !stop.get() && !err && !Thread.currentThread().isInterrupted()) { Integer key = rnd.nextInt(PARTS); Integer val = valCntr.incrementAndGet();