from: flink-connector-elasticsearch7 to: flink-connector-elasticsearch-base evidence: - file: "flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/ElasticsearchSink.java" contains "import org.apache.flink.streaming.connectors.elasticsearch.ActionRequestFailureHandler;" from: flink-connector-elasticsearch7 to: flink-connector-elasticsearch-base evidence: - file: "flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7ApiCallBridge.java" contains "import org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchApiCallBridge;" from: flink-connector-elasticsearch7 to: flink-connector-elasticsearch-base evidence: - file: "flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7BulkProcessorIndexer.java" contains "import org.apache.flink.streaming.connectors.elasticsearch.RequestIndexer;" from: flink-connector-elasticsearch6 to: flink-connector-elasticsearch-base evidence: - file: "flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6BulkProcessorIndexer.java" contains "import org.apache.flink.streaming.connectors.elasticsearch.RequestIndexer;" from: flink-connector-elasticsearch6 to: flink-connector-elasticsearch-base evidence: - file: "flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSink.java" contains "import org.apache.flink.streaming.connectors.elasticsearch.ActionRequestFailureHandler;" from: flink-connector-elasticsearch6 to: flink-connector-elasticsearch-base evidence: - file: "flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6ApiCallBridge.java" contains "import org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchApiCallBridge;"