java连接es7.1.1 集群添加 数据失败

java 语句 执行异常
IndexResponse indexResponse = this.client.index(indexRequest,RequestOptions.DEFAULT)

java.lang.IllegalStateException: Request cannot be executed; I/O reactor status: STOPPED
 

public class TestHighLevel {



    private RestHighLevelClient client ;



    @Before

    public void init() {

        RestClientBuilder restClientBuilder = RestClient.builder(new HttpHost("192.168.0.8", 9200, "http"),

                new HttpHost("192.168.0.11", 9200, "http"),

                new HttpHost("192.168.0.15", 9200, "http"));



        this.client = new RestHighLevelClient(restClientBuilder) ;

    }



    @After

    public void after() throws Exception {



        client.close();

    }



    @Test

    public void testCreate() throws Exception {

        HashMap<String, Object> data = new HashMap<>();after();

        data.put("id", "3003") ;

        data.put("title", "北京出租小仓库，小库房，寄存家具物品，公司货物企业档案") ;

        data.put("price", "3700") ;



        IndexRequest indexRequest = new IndexRequest("posts").source(data);

        System.out.println("shardInof ->" + indexResponse.getShardInfo());

    }

}

异常

java.lang.RuntimeException: Request cannot be executed; I/O reactor status: STOPPED



	at org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:831)

	at org.elasticsearch.client.RestClient.performRequest(RestClient.java:248)

	at org.elasticsearch.client.RestClient.performRequest(RestClient.java:251)

	at org.elasticsearch.client.RestClient.performRequest(RestClient.java:251)

	at org.elasticsearch.client.RestClient.performRequest(RestClient.java:235)

	at org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1514)

	at org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1484)

	at org.elasticsearch.client.RestHighLevelClient.performRequestAndParseEntity(RestHighLevelClient.java:1454)

	at org.elasticsearch.client.RestHighLevelClient.index(RestHighLevelClient.java:871)

	at edu.athome.eshighlevel.TestHighLevel.testCreate(TestHighLevel.java:58)

	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

	at java.base/java.lang.reflect.Method.invoke(Method.java:566)

	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)

	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)

	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)

	at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)

	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)

	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)

	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)

	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)

	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)

	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)

	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)

	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)

	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)

	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)

	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)

	at org.junit.runner.JUnitCore.run(JUnitCore.java:137)

	at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:68)

	at com.intellij.rt.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:33)

	at com.intellij.rt.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:230)

	at com.intellij.rt.junit.JUnitStarter.main(JUnitStarter.java:58)

	Suppressed: java.lang.RuntimeException: Request cannot be executed; I/O reactor status: STOPPED

		at org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:831)

		at org.elasticsearch.client.RestClient.performRequest(RestClient.java:248)

		... 31 more

		Suppressed: java.lang.RuntimeException: Request cannot be executed; I/O reactor status: STOPPED

			at org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:831)

			at org.elasticsearch.client.RestClient.performRequest(RestClient.java:248)

			... 30 more

		Caused by: java.lang.IllegalStateException: Request cannot be executed; I/O reactor status: STOPPED

			at org.apache.http.util.Asserts.check(Asserts.java:46)

			at org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase.ensureRunning(CloseableHttpAsyncClientBase.java:90)

			at org.apache.http.impl.nio.client.InternalHttpAsyncClient.execute(InternalHttpAsyncClient.java:123)

			at org.elasticsearch.client.RestClient.performRequest(RestClient.java:244)

			... 30 more

	Caused by: java.lang.IllegalStateException: Request cannot be executed; I/O reactor status: STOPPED

		at org.apache.http.util.Asserts.check(Asserts.java:46)

		at org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase.ensureRunning(CloseableHttpAsyncClientBase.java:90)

		at org.apache.http.impl.nio.client.InternalHttpAsyncClient.execute(InternalHttpAsyncClient.java:123)

		at org.elasticsearch.client.RestClient.performRequest(RestClient.java:244)

		... 31 more

Caused by: java.lang.IllegalStateException: Request cannot be executed; I/O reactor status: STOPPED

	at org.apache.http.util.Asserts.check(Asserts.java:46)

	at org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase.ensureRunning(CloseableHttpAsyncClientBase.java:90)

	at org.apache.http.impl.nio.client.InternalHttpAsyncClient.execute(InternalHttpAsyncClient.java:123)

	at org.elasticsearch.client.RestClient.performRequest(RestClient.java:244)

	... 32 more





Process finished with exit code -1

应该怎么写？？？？？？？？？？？？？？？？？