ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [1/2] ignite git commit: Index worker stop.
Date Mon, 20 Mar 2017 08:19:14 GMT
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 <vozerov@gridgain.com>
Authored: Mon Mar 20 11:14:06 2017 +0300
Committer: devozerov <vozerov@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();
     }
 


Mime
View raw message