This is an automated email from the ASF dual-hosted git repository.
aloyszhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 590e46ebe3 [INLONG-10289][Agent] Update the SQLServer Source (#10735)
add 3af0a7f768 [INLONG-10721][Sort] Add elasticsearch7 connector on flink
1.18 (#10741)
No new revisions were added by this update.
Summary of changes:
.../{elasticsearch6 => elasticsearch7}/pom.xml | 18 +++++++---
.../Elasticsearch7ApiCallBridge.java} | 23 ++++++------
.../Elasticsearch7BulkProcessorIndexer.java} | 9 +++--
.../sort/elasticsearch7}/ElasticsearchSink.java | 12 +++----
.../table/Elasticsearch7Configuration.java} | 21 +++--------
.../table/Elasticsearch7DynamicSink.java} | 42 +++++++++++-----------
.../table/Elasticsearch7DynamicSinkFactory.java} | 40 +++++++--------------
.../org.apache.flink.table.factories.Factory | 1 -
.../sort-flink-v1.18/sort-connectors/pom.xml | 1 +
licenses/inlong-sort-connectors/LICENSE | 13 +++++--
10 files changed, 84 insertions(+), 96 deletions(-)
copy inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/{elasticsearch6
=> elasticsearch7}/pom.xml (89%)
copy
inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/{elasticsearch6/src/main/java/org/apache/inlong/sort/elasticsearch6/Elasticsearch6ApiCallBridge.java
=>
elasticsearch7/src/main/java/org/apache/inlong/sort/elasticsearch7/Elasticsearch7ApiCallBridge.java}
(89%)
copy
inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/{elasticsearch6/src/main/java/org/apache/inlong/sort/elasticsearch6/Elasticsearch6BulkProcessorIndexer.java
=>
elasticsearch7/src/main/java/org/apache/inlong/sort/elasticsearch7/Elasticsearch7BulkProcessorIndexer.java}
(89%)
copy
inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/{elasticsearch6/src/main/java/org/apache/inlong/sort/elasticsearch6
=>
elasticsearch7/src/main/java/org/apache/inlong/sort/elasticsearch7}/ElasticsearchSink.java
(96%)
copy
inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/{elasticsearch6/src/main/java/org/apache/inlong/sort/elasticsearch6/table/Elasticsearch6Configuration.java
=>
elasticsearch7/src/main/java/org/apache/inlong/sort/elasticsearch7/table/Elasticsearch7Configuration.java}
(81%)
copy
inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/{elasticsearch6/src/main/java/org/apache/inlong/sort/elasticsearch6/table/Elasticsearch6DynamicSink.java
=>
elasticsearch7/src/main/java/org/apache/inlong/sort/elasticsearch7/table/Elasticsearch7DynamicSink.java}
(91%)
copy
inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/{elasticsearch6/src/main/java/org/apache/inlong/sort/elasticsearch6/table/Elasticsearch6DynamicSinkFactory.java
=>
elasticsearch7/src/main/java/org/apache/inlong/sort/elasticsearch7/table/Elasticsearch7DynamicSinkFactory.java}
(72%)
copy inlong-sort/sort-flink/{sort-flink-v1.13/sort-connectors/elasticsearch-7
=>
sort-flink-v1.18/sort-connectors/elasticsearch7}/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
(99%)
