2015-01-14 4 views
7

Ich erstelle eine TransportClient-Instanz in elasticsearch. Unten ist der Code für dasselbe. Das Problem ist, dass ich versuche, die Anzahl der Threads zu verringern, die mit dem Threadpool erzeugt werden, den der TransportClient initiiert. Aber egal welche Einstellungen ich benutze, mein elasticsearch initialisiert immer den Threadpool mit 12 Threads. Bitte lassen Sie mich wissen, wie Sie das gleiche konfigurieren, um die gewünschten Threads zu erhalten.Anzahl der Threads in ThreadPool beim Erstellen von 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

kann jemand vorschlagen? – bagui

+0

haben Sie die Lösung dafür bekommen? –

+0

Ich habe keine Lösung – bagui

Antwort

Verwandte Themen