run in J2SE, when shutdownClient, the jvm still hang.

[zykaka]

test the code like:

    client.shutdownClient();

    System.out.println("terminated!");

The main thread exists but the whole JVM still hold by the execution service.

Fix could be in the NodeChecker:

protected void shutDown() throws Exception{
    super.shutDown();
    client = null;
    clientConfig = null;

    executorService.shutdown();
}

protected ScheduledExecutorService executor() {
    executorService =
            Executors.newSingleThreadScheduledExecutor();
    return executorService;
}

[ferhatsb]

Which version are you running , snapshot ?

[zykaka]

snapshot of master

[zykaka]

Sample test code:

package abc.test;

import io.searchbox.client.JestClient;
import io.searchbox.client.JestClientFactory;
import io.searchbox.client.JestResult;
import io.searchbox.client.config.ClientConfig;
import io.searchbox.core.Search;

import java.util.concurrent.TimeUnit;

public class JestTest {

/**
 * @param args
 * @throws Exception 
 */
public static void main(String[] args) throws Exception {

    // Configuration
    ClientConfig clientConfig = 
            new ClientConfig.Builder("http://localhost:9200")
    .multiThreaded(true).discoveryEnabled(true)
    .discoveryFrequency(1l, TimeUnit.SECONDS).maxTotalConnection(100).build();

    // Construct a new Jest client according to configuration via factory
    JestClientFactory factory = new JestClientFactory();
    factory.setClientConfig(clientConfig);
    JestClient client = factory.getObject();


    String query = "{\n" +
            "    \"query\": {\n" +
            "        \"filtered\" : {\n" +
            "            \"query\" : {\n" +
            "                \"query_string\" : {\n" +
            "                    \"query\" : \"search\"\n" +
            "                }\n" +
            "            },\n" +
            "            \"filter\" : {\n" +
            "                \"term\" : { \"user\" : \"kimchy\" }\n" +
            "            }\n" +
            "        }\n" +
            "    }\n" +
            "}"; 


    Thread.sleep(2000);

    Search search = new Search.Builder(query)
    // multiple index or types can be added.
    .addIndex("twitter").addType("tweet")
    .build();

    for(int i=0; i<10; i++){
        JestResult result = client.execute(search); 

        System.out.println(result.getJsonString());
    }

    client.shutdownClient();

    System.out.println("terminated!");
}

}

This new process will never stops.

[kramer]

I still cannot reproduce the issue even with the sample code you provided... When I run your sample code, both main thread and the JVM properly terminates. Are you customizing/overwriting any of the Jest classes, maybe that's the issue?

[ferhatsb]

@zykaka which jdk/jvm version you are using?

[zykaka]

IBM jdk 6.0

[ferhatsb]

Closing this, guess this bug is only happens with IBM JDK.