diff --git a/elasticsearch/x-pack/marvel/src/main/java/org/elasticsearch/marvel/cleaner/CleanerService.java b/elasticsearch/x-pack/marvel/src/main/java/org/elasticsearch/marvel/cleaner/CleanerService.java index 8804ecc7b42..b36a91c598e 100644 --- a/elasticsearch/x-pack/marvel/src/main/java/org/elasticsearch/marvel/cleaner/CleanerService.java +++ b/elasticsearch/x-pack/marvel/src/main/java/org/elasticsearch/marvel/cleaner/CleanerService.java @@ -67,7 +67,9 @@ public class CleanerService extends AbstractLifecycleComponent { @Override protected void doClose() { logger.debug("closing cleaning service"); - runnable.cancel(); + if (runnable != null) { + runnable.cancel(); + } logger.debug("cleaning service closed"); } diff --git a/elasticsearch/x-pack/watcher/src/main/java/org/elasticsearch/watcher/support/http/HttpClient.java b/elasticsearch/x-pack/watcher/src/main/java/org/elasticsearch/watcher/support/http/HttpClient.java index 5d9082ea5b0..dc751ee27d2 100644 --- a/elasticsearch/x-pack/watcher/src/main/java/org/elasticsearch/watcher/support/http/HttpClient.java +++ b/elasticsearch/x-pack/watcher/src/main/java/org/elasticsearch/watcher/support/http/HttpClient.java @@ -281,7 +281,7 @@ public class HttpClient extends AbstractLifecycleComponent { if (keyStore == null) { return null; } - Path path = env.binFile().getParent().resolve(keyStore); + Path path = env.configFile().resolve(keyStore); if (Files.notExists(path)) { return null; } @@ -304,7 +304,7 @@ public class HttpClient extends AbstractLifecycleComponent { // Load TrustStore KeyStore ks = null; if (trustStore != null) { - Path trustStorePath = env.binFile().getParent().resolve(trustStore); + Path trustStorePath = env.configFile().resolve(trustStore); if (Files.exists(trustStorePath)) { ks = readKeystore(trustStorePath, trustStorePassword); }