diff options
author | Areek Zillur <areek.zillur@elasticsearch.com> | 2016-10-11 16:04:47 -0400 |
---|---|---|
committer | Areek Zillur <areek.zillur@elasticsearch.com> | 2016-10-11 16:04:47 -0400 |
commit | 481f7909aebec0d73502d61f703ddd8185cb3783 (patch) | |
tree | 44850834084df756d89308a40cb06c032147343e /core/src/test/java/org/elasticsearch/action/ingest | |
parent | 0e8b6532ecc9e38c689b64ebb178271085e69c80 (diff) | |
parent | 298cf1cf21b7f1fe0077daf185a8a66267f56ea4 (diff) |
Merge branch 'master' into cleanup/transport_bulk
Diffstat (limited to 'core/src/test/java/org/elasticsearch/action/ingest')
-rw-r--r-- | core/src/test/java/org/elasticsearch/action/ingest/IngestProxyActionFilterTests.java | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/core/src/test/java/org/elasticsearch/action/ingest/IngestProxyActionFilterTests.java b/core/src/test/java/org/elasticsearch/action/ingest/IngestProxyActionFilterTests.java index 50bd3771bc..5190f7e12c 100644 --- a/core/src/test/java/org/elasticsearch/action/ingest/IngestProxyActionFilterTests.java +++ b/core/src/test/java/org/elasticsearch/action/ingest/IngestProxyActionFilterTests.java @@ -34,7 +34,6 @@ import org.elasticsearch.cluster.node.DiscoveryNode; import org.elasticsearch.cluster.node.DiscoveryNodes; import org.elasticsearch.cluster.service.ClusterService; import org.elasticsearch.common.settings.Settings; -import org.elasticsearch.common.transport.LocalTransportAddress; import org.elasticsearch.tasks.Task; import org.elasticsearch.test.ESTestCase; import org.elasticsearch.test.VersionUtils; @@ -79,7 +78,7 @@ public class IngestProxyActionFilterTests extends ESTestCase { if (i < ingestNodes) { roles.add(DiscoveryNode.Role.INGEST); } - DiscoveryNode node = new DiscoveryNode(nodeId, nodeId, LocalTransportAddress.buildUnique(), attributes, roles, VersionUtils.randomVersion(random())); + DiscoveryNode node = new DiscoveryNode(nodeId, nodeId, buildNewFakeTransportAddress(), attributes, roles, VersionUtils.randomVersion(random())); builder.add(node); if (i == totalNodes - 1) { localNode = node; @@ -89,7 +88,7 @@ public class IngestProxyActionFilterTests extends ESTestCase { ClusterService clusterService = mock(ClusterService.class); when(clusterService.localNode()).thenReturn(localNode); when(clusterService.state()).thenReturn(clusterState.build()); - transportService = new TransportService(Settings.EMPTY, null, null, interceptor); + transportService = new TransportService(Settings.EMPTY, null, null, interceptor, null); return new IngestProxyActionFilter(clusterService, transportService); } |