diff options
| author | Jon Marius Venstad <venstad@gmail.com> | 2021-01-12 16:00:51 +0100 |
|---|---|---|
| committer | Jon Marius Venstad <venstad@gmail.com> | 2021-01-12 16:00:51 +0100 |
| commit | 7fe6943d6409a4d8838fb1c618e10b8dfae40382 (patch) | |
| tree | abd3154941b03bc601d41842bfb6384c974c6b8c /clustercontroller-reindexer | |
| parent | eb70f1281832128b18b09d12cfa3d8b87b683cff (diff) | |
More foreceful reindexing shutdown
Diffstat (limited to 'clustercontroller-reindexer')
| -rw-r--r-- | clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingMaintainer.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingMaintainer.java b/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingMaintainer.java index e62314429fb..9cb1981c230 100644 --- a/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingMaintainer.java +++ b/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingMaintainer.java @@ -110,7 +110,8 @@ public class ReindexingMaintainer extends AbstractComponent { log.log(WARNING, "Interrupted while waiting for reindexing to shut down"); Thread.currentThread().interrupt(); } - + if ( ! executor.isShutdown()) + executor.shutdownNow(); } static Map<DocumentType, Instant> parseReady(ReindexingConfig.Clusters cluster, DocumentTypeManager manager) { |