組み込みElasticSearchは統合テストでトランスポートに接続できません

Question

統合テスト用の埋め込み型ElasticSearchノードを作成しようとしています。ここで

は、コード作成されたコードで

private static final String THREAD_NAME = "ES-THREAD"; 
private static final String CLUSTER_NAME = "ES-INTEGRATION-TEST"; 
private static final String ES_HOME_PATH = "elastic-search-home"; 
private static final String ES_DATA_PATH = "elastic-search-data"; 
private static final String DATA_PORTS = "9500-9599"; 
private static final String TRANSPORT_PORTS = "9600-9699"; 
public void before() throws Throwable { 
     try { 
      homeDir = Files.createTempDirectory(ES_HOME_PATH); 
      dataDir = Files.createTempDirectory(ES_DATA_PATH); 

      log.info("Created temp directory {} and {}", homeDir, dataDir); 
     } catch (IOException ex) { 
      throw new IllegalStateException("Temp Elastic Search directory not created", ex); 
     } 

     Properties props = new Properties(); 

     props.setProperty("name", THREAD_NAME); 
     props.setProperty("path.home", homeDir.toString()); 
     props.setProperty("path.data", dataDir.toString()); 
     props.setProperty("http.port", DATA_PORTS); 
     props.setProperty("transport.tcp.port", TRANSPORT_PORTS); 
     props.setProperty("node.local", "true"); 
     props.setProperty("script.groovy.sandbox.enabled", "true"); 
     props.setProperty("script.engine.groovy.inline.aggs", "true"); 
     props.setProperty("script.engine.groovy.inline.search", "true"); 
     props.setProperty("script.engine.groovy.inline.update", "true"); 
     props.setProperty("script.engine.groovy.inline.mapping", "true"); 


     esNode = NodeBuilder.nodeBuilder().local(false).client(false) 
       .settings(Settings.settingsBuilder().put(props).build()).clusterName(CLUSTER_NAME).build(); 

     esNode.start(); 
} 

は私がexcepetion

java.net.BindException: Can't assign requested address 
    at sun.nio.ch.Net.connect0(Native Method) 
    at sun.nio.ch.Net.connect(Net.java:454) 
    at sun.nio.ch.Net.connect(Net.java:446) 
    at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:648) 
    at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:108) 
    at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:70) 
    at org.jboss.netty.channel.DefaultChannelPipeline.sendDownstream(DefaultChannelPipeline.java:574) 
    at org.jboss.netty.channel.Channels.connect(Channels.java:634) 
    at org.jboss.netty.channel.AbstractChannel.connect(AbstractChannel.java:216) 
    at org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:229) 
    at org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:182) 
    at org.elasticsearch.transport.netty.NettyTransport.connectToChannelsLight(NettyTransport.java:913) 
    at org.elasticsearch.transport.netty.NettyTransport.connectToNode(NettyTransport.java:880) 
    at org.elasticsearch.transport.netty.NettyTransport.connectToNodeLight(NettyTransport.java:852) 
    at org.elasticsearch.transport.TransportService.connectToNodeLight(TransportService.java:250) 
    at org.elasticsearch.client.transport.TransportClientNodesService$SimpleNodeSampler.doSample(TransportClientNodesService.java:354) 
    at org.elasticsearch.client.transport.TransportClientNodesService$NodeSampler.sample(TransportClientNodesService.java:300) 
    at org.elasticsearch.client.transport.TransportClientNodesService$ScheduledNodeSampler.run(TransportClientNodesService.java:333) 
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 
    at java.lang.Thread.run(Thread.java:745) 

を受けるテストを実行すると

private Client createClient() throws UnknownHostException { 
    Settings.Builder builder = Settings.builder(); 
    builder.put("cluster.name", clusterName); 
    builder.put("client.transport.ignore_cluster_name", true); 

    Settings settings = builder.build(); 
    return TransportClient.builder().settings(settings).build() 
      .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(hostname), port)); 
} 

をElasticSearchするトランスポート接続を作成し、以下の方法がありますテスト

テストコードのホスト名として送信する値は、l ocalhostと私は

NodeInfo nodeInfo = esNode.client().admin().cluster().prepareNodesInfo(localNodeId).get().iterator().next(); 
transportAddress = nodeInfo.getTransport().address().publishAddress().getAddress(); 

で私が埋め込まElasticSearchから引っ張って送信ポートを、私はその値がローカルである）、トランスポートポートは常に0であることを見て、私はnodeInfo.getTransportを評価する際に（）。（アドレス[1]。

ノード作成で何が間違っていますか？ 追加する必要がある別の設定はありますか？

おかげで、

ダニエラ

Answer 1

私はprops.setPropertyを変更したとき（ "node.local" "真"）; to props.setProperty（ "node.local"、 "false"）;トランスポートポートが作成されました。