You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by sh...@apache.org on 2018/04/02 07:38:19 UTC
[32/34] lucene-solr:jira/solr-12095: SOLR-7736: break
OverseerTriggerThread when interrupted.
SOLR-7736: break OverseerTriggerThread when interrupted.
Project: http://git-wip-us.apache.org/repos/asf/lucene-solr/repo
Commit: http://git-wip-us.apache.org/repos/asf/lucene-solr/commit/a4789db4
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/a4789db4
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/a4789db4
Branch: refs/heads/jira/solr-12095
Commit: a4789db47788daeef0ba2ab426b4047d2fa47070
Parents: 7a920cb
Author: Mikhail Khludnev <mk...@apache.org>
Authored: Sun Apr 1 18:37:18 2018 +0300
Committer: Mikhail Khludnev <mk...@apache.org>
Committed: Sun Apr 1 18:37:18 2018 +0300
----------------------------------------------------------------------
.../org/apache/solr/cloud/autoscaling/OverseerTriggerThread.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/a4789db4/solr/core/src/java/org/apache/solr/cloud/autoscaling/OverseerTriggerThread.java
----------------------------------------------------------------------
diff --git a/solr/core/src/java/org/apache/solr/cloud/autoscaling/OverseerTriggerThread.java b/solr/core/src/java/org/apache/solr/cloud/autoscaling/OverseerTriggerThread.java
index f97372d..874122d 100644
--- a/solr/core/src/java/org/apache/solr/cloud/autoscaling/OverseerTriggerThread.java
+++ b/solr/core/src/java/org/apache/solr/cloud/autoscaling/OverseerTriggerThread.java
@@ -124,6 +124,10 @@ public class OverseerTriggerThread implements Runnable, SolrCloseable {
// we also automatically add a scheduled maintenance trigger
while (!isClosed) {
try {
+ if (Thread.currentThread().isInterrupted()) {
+ log.warn("Interrupted");
+ break;
+ }
AutoScalingConfig autoScalingConfig = cloudManager.getDistribStateManager().getAutoScalingConfig();
AutoScalingConfig updatedConfig = withAutoAddReplicasTrigger(autoScalingConfig);
updatedConfig = withScheduledMaintenanceTrigger(updatedConfig);