Github user yew1eb commented on a diff in the pull request:
https://github.com/apache/flink/pull/5374#discussion_r164961589
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java
---
@@ -32,7 +32,6 @@
import org.elasticsearch.action.bulk.BulkProcessor;
import org.elasticsearch.action.bulk.BulkRequest;
import org.elasticsearch.action.bulk.BulkResponse;
-import org.elasticsearch.client.Client;
--- End diff --
Should not be deleted, be used for {@link Client}.
---
