2015-01-14 17 views
7

Elasticsearch içinde bir TransportClient örneği oluşturuyorum. Aşağıda aynı kod var. Sorun, TransportClient'in başlattığı threadpool ile oluşturulan iplik sayısını azaltmaya çalışıyorum. Ama hangi ayarları benim elasticsearch kullanıyorum her zaman thread thread 12 thread ile başlangıç. İstediğiniz konuları almak için lütfen nasıl yapılandırılacağını bana bildirin.sınır iplik sayısı

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

alınan JanuZ için

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

Kredi, deneyin? – bagui

+0

bunun için çözüm buldunuz mu? –

+0

Çözüme ulaşmadım – bagui

cevap