diff --git a/plugins/repository-azure/src/test/java/org/elasticsearch/repositories/azure/AzureRepositoryF.java b/plugins/repository-azure/src/test/java/org/elasticsearch/repositories/azure/AzureRepositoryF.java index 771344d56eb..b75cfb59479 100644 --- a/plugins/repository-azure/src/test/java/org/elasticsearch/repositories/azure/AzureRepositoryF.java +++ b/plugins/repository-azure/src/test/java/org/elasticsearch/repositories/azure/AzureRepositoryF.java @@ -19,12 +19,15 @@ package org.elasticsearch.repositories.azure; +import org.apache.lucene.util.IOUtils; +import org.elasticsearch.ElasticsearchException; import org.elasticsearch.Version; import org.elasticsearch.common.settings.Settings; import org.elasticsearch.node.MockNode; import org.elasticsearch.node.Node; import org.elasticsearch.plugin.repository.azure.AzureRepositoryPlugin; +import java.io.IOException; import java.util.Collections; import java.util.concurrent.CountDownLatch; @@ -112,7 +115,11 @@ public class AzureRepositoryF { Runtime.getRuntime().addShutdownHook(new Thread() { @Override public void run() { - node.close(); + try { + IOUtils.close(node); + } catch (IOException e) { + throw new ElasticsearchException(e); + } latch.countDown(); } }); diff --git a/qa/evil-tests/src/test/java/org/elasticsearch/tribe/TribeUnitTests.java b/qa/evil-tests/src/test/java/org/elasticsearch/tribe/TribeUnitTests.java index 1756e6b7dad..ca9f5aa96a7 100644 --- a/qa/evil-tests/src/test/java/org/elasticsearch/tribe/TribeUnitTests.java +++ b/qa/evil-tests/src/test/java/org/elasticsearch/tribe/TribeUnitTests.java @@ -19,6 +19,7 @@ package org.elasticsearch.tribe; +import org.apache.lucene.util.IOUtils; import org.elasticsearch.client.Client; import org.elasticsearch.cluster.ClusterState; import org.elasticsearch.cluster.node.DiscoveryNode; @@ -34,6 +35,7 @@ import org.elasticsearch.test.InternalTestCluster; import org.junit.AfterClass; import org.junit.BeforeClass; +import java.io.IOException; import java.nio.file.Path; import static org.hamcrest.CoreMatchers.either; @@ -76,10 +78,9 @@ public class TribeUnitTests extends ESTestCase { } @AfterClass - public static void closeTribes() { - tribe1.close(); + public static void closeTribes() throws IOException { + IOUtils.close(tribe1, tribe2); tribe1 = null; - tribe2.close(); tribe2 = null; }