2015-01-14 16 views
7

Sto creando un'istanza TransportClient in elasticsearch. Di seguito è riportato il codice per lo stesso. Il problema è che sto cercando di ridurre il numero di thread generati con il threadpool avviato da TransportClient. Ma quali sono le impostazioni, utilizzo sempre il mio elasticsearch iniziando il threadpool con 12 thread. Per favore fatemi sapere come configurare lo stesso per ottenere i thread desiderabili.numero limite di thread in ThreadPool durante la creazione di TransportClient in elasticsearch

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

qualcuno può suggerire? – bagui

+0

hai trovato la soluzione per questo? –

+0

Non ho la soluzione – bagui

risposta

Problemi correlati