[FLINK-25313][connector-elasticsearch] Remove legacy Elasticseach con…

…nector Use the new connector via option 'connector' = 'elasticsearch-7'.
zhuoluoy · Aug 4, 2021 · a942322 · a942322
1 parent f367a22
commit a942322
Show file tree

Hide file tree

Showing 16 changed files with 1 addition and 3,600 deletions.
diff --git a/...org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java b/...org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java
diff --git a/...che/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkFactoryBase.java b/...che/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkFactoryBase.java
diff --git a/...or-elasticsearch-base/src/main/java/org/apache/flink/table/descriptors/Elasticsearch.java b/...or-elasticsearch-base/src/main/java/org/apache/flink/table/descriptors/Elasticsearch.java