flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/Elasticsearch6ApiCallBridge.java [58:66]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        SearchHit[] searchHits = searchResponse.getHits().getHits();
        return new Tuple2<>(
                searchResponse.getScrollId(),
                Stream.of(searchHits).map(SearchHit::getSourceAsString).toArray(String[]::new));
    }

    @Override
    public void close(RestHighLevelClient client) throws IOException {
        client.close();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/Elasticsearch7ApiCallBridge.java [59:67]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        SearchHit[] searchHits = searchResponse.getHits().getHits();
        return new Tuple2<>(
                searchResponse.getScrollId(),
                Stream.of(searchHits).map(SearchHit::getSourceAsString).toArray(String[]::new));
    }

    @Override
    public void close(RestHighLevelClient client) throws IOException {
        client.close();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -