在flink的sink的invoke方法里面使用RestHighLevelClient的indexAPI写入数据的时候，总是报错

java.lang.RuntimeException: Request cannot be executed; I/O reactor status: STOPPED
at org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:831) ~[data-audit-photo-history-modify-2.1.jar:?]
at org.elasticsearch.client.RestClient.performRequest(RestClient.java:248) ~[data-audit-photo-history-modify-2.1.jar:?]
at org.elasticsearch.client.RestClient.performRequest(RestClient.java:251) ~[data-audit-photo-history-modify-2.1.jar:?]
at org.elasticsearch.client.RestClient.performRequest(RestClient.java:251) ~[data-audit-photo-history-modify-2.1.jar:?]
at org.elasticsearch.client.RestClient.performRequest(RestClient.java:235) ~[data-audit-photo-history-modify-2.1.jar:?]
at org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1514) ~[data-audit-photo-history-modify-2.1.jar:?]
at org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1484) ~[data-audit-photo-history-modify-2.1.jar:?]
at org.elasticsearch.client.RestHighLevelClient.performRequestAndParseEntity(RestHighLevelClient.java:1454) ~[data-audit-photo-history-modify-2.1.jar:?]
at org.elasticsearch.client.RestHighLevelClient.get(RestHighLevelClient.java:742) ~[data-audit-photo-history-modify-2.1.jar:?]
at com.chinaunicom.audit.photo.history.handle.customsink.HbaseConstientModifySink.searchPhotoInfoByTradeIdFromElastcsearch(HbaseConstientModifySink.java:653) ~


653行的错误报的错的自己写的代码是 GetResponse getResponse = highLevelClient.get(getRequest, RequestOptions.DEFAULT);，这行我也看不出来有什么错误。