2015-01-14 10 views
7

elasticsearchにTransportClientインスタンスを作成しています。以下は同じもののためのコードです。問題は、TransportClientが開始するスレッドプールで生成されたスレッドの数を減らそうとしていることです。しかし、これまでの設定では、私のelasticsearchは常にスレッドプールを12スレッドで初期化しています。望ましいスレッドを得るために同じものを設定する方法を教えてください。elasticsearchにTransportClientを作成する際のThreadPoolのスレッド数を制限します

public static TransportClient getTransportClient(String ip, int port) { 

    ImmutableSettings.Builder settings = ImmutableSettings 
      .settingsBuilder(); 
    settings.put("cluster.name", "elasticsearch"); 
    settings.put("threadpool.bulk.type", "fixed"); 
    settings.put("threadpool.bulk.size" ,5); 
    settings.put("threadpool.bulk.queue_size", 5); 
    settings.put("threadpool.index.type" , "fixed"); 
    settings.put("threadpool.index.size" , 5); 
    settings.put("threadpool.index.queue_size" , 10); 
    settings.put("threadpool.search.type", "fixed"); 
    settings.put("threadpool.search.size" ,5); 
    settings.put("threadpool.search.queue_size", 5); 

    settings.build(); 

    TransportClient instance = new TransportClient(settings) 
      .addTransportAddress(new InetSocketTransportAddress(ip, port)); 

    return instance; 
} 
+0

から取らJanuZへ

Settings settings = ImmutableSettings.settingsBuilder() .put("transport.netty.workerCount",NUM_THREADS) .build(); 

クレジットを、試してみてください? – bagui

+0

あなたはこれに対する解決策を得ましたか? –

+0

私は解決策を得ていない – bagui

答えて

関連する問題