diff --git a/src/test/java/org/elasticsearch/action/bulk/BulkProcessorTests.java b/src/test/java/org/elasticsearch/action/bulk/BulkProcessorTests.java
index 89aa88c029d..ef5ac5171e9 100644
--- a/src/test/java/org/elasticsearch/action/bulk/BulkProcessorTests.java
+++ b/src/test/java/org/elasticsearch/action/bulk/BulkProcessorTests.java
@@ -187,6 +187,7 @@ public class BulkProcessorTests extends ElasticsearchIntegrationTest {
 
         assertThat(listener.bulkFailures.size(), equalTo(totalExpectedBulkActions));
         assertThat(listener.bulkItems.size(), equalTo(0));
+        transportClient.close();
     }
 
     @Test
diff --git a/src/test/java/org/elasticsearch/tribe/TribeTests.java b/src/test/java/org/elasticsearch/tribe/TribeTests.java
index 45c6c67fc8c..1c8284ff0fd 100644
--- a/src/test/java/org/elasticsearch/tribe/TribeTests.java
+++ b/src/test/java/org/elasticsearch/tribe/TribeTests.java
@@ -19,7 +19,6 @@
 
 package org.elasticsearch.tribe;
 
-import com.google.common.base.Predicate;
 import com.google.common.collect.ImmutableMap;
 import org.elasticsearch.action.admin.cluster.health.ClusterHealthStatus;
 import org.elasticsearch.client.Client;
@@ -111,6 +110,7 @@ public class TribeTests extends ElasticsearchIntegrationTest {
                 .put(tribe1Defaults.build())
                 .put(tribe2Defaults.build())
                 .put(internalCluster().getDefaultSettings())
+                .put("node.name", "tribe_node") // make sure we can identify threads from this node
                 .build();
 
         tribeNode = NodeBuilder.nodeBuilder()