Repository: ignite Updated Branches: refs/heads/ignite-4565-ddl 69cac4f3a -> d6e5028db
Index worker stop. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/04b49c7e Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/04b49c7e Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/04b49c7e Branch: refs/heads/ignite-4565-ddl Commit: 04b49c7e75c21540179c3f0e0b82bb3da55af700 Parents: 69cac4f Author: devozerov <voze...@gridgain.com> Authored: Mon Mar 20 11:14:06 2017 +0300 Committer: devozerov <voze...@gridgain.com> Committed: Mon Mar 20 11:14:06 2017 +0300 ---------------------------------------------------------------------- .../internal/processors/query/GridQueryProcessor.java | 9 +++++++++ 1 file changed, 9 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/04b49c7e/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryProcessor.java index 32322c3..58f577e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryProcessor.java @@ -271,6 +271,15 @@ public class GridQueryProcessor extends GridProcessorAdapter { } } + idxWorker.cancel(); + + try { + idxWorker.join(); + } + catch (InterruptedException e) { + U.warn(log, "Failed to wait for index worker stop due to interrupt.", e); + } + busyLock.block(); }
