This is an automated email from the ASF dual-hosted git repository.
zirui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 3af0a7f768 [INLONG-10721][Sort] Add elasticsearch7 connector on flink
1.18 (#10741)
add 4eee655437 [INLONG-10739][Sort] Add Elasticsearch connector base on
flink1.15 (#10740)
No new revisions were added by this update.
Summary of changes:
.../sort-connectors/elasticsearch-base/pom.xml | 6 ++---
.../elasticsearch/ActionRequestFailureHandler.java | 0
.../elasticsearch/BufferingNoOpRequestIndexer.java | 4 +---
.../elasticsearch/ElasticsearchApiCallBridge.java | 6 ++---
.../sort/elasticsearch/ElasticsearchSinkBase.java | 21 ++++++++++++----
.../elasticsearch/ElasticsearchSinkFunction.java | 10 +-------
.../inlong/sort/elasticsearch/RequestIndexer.java | 1 +
.../table/AbstractTimeIndexGenerator.java | 0
.../table/ElasticsearchConfiguration.java | 28 ++++++++++++----------
.../table/ElasticsearchConnectorOptions.java | 5 +---
.../table/ElasticsearchValidationUtils.java | 2 --
.../sort/elasticsearch/table/IndexGenerator.java | 1 -
.../elasticsearch/table/IndexGeneratorBase.java | 0
.../elasticsearch/table/IndexGeneratorFactory.java | 2 --
.../sort/elasticsearch/table/KeyExtractor.java | 0
.../sort/elasticsearch/table/RequestFactory.java | 2 --
.../table/RowElasticsearchSinkFunction.java | 7 +-----
.../elasticsearch/table/StaticIndexGenerator.java | 2 --
.../elasticsearch/util/IgnoringFailureHandler.java | 2 --
.../elasticsearch/util/NoOpFailureHandler.java | 2 --
.../util/RetryRejectedExecutionFailureHandler.java | 0
.../sort-flink-v1.15/sort-connectors/pom.xml | 1 +
licenses/inlong-sort-connectors/LICENSE | 21 ++++++++++++++++
23 files changed, 66 insertions(+), 57 deletions(-)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/elasticsearch-base/pom.xml (97%)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/ActionRequestFailureHandler.java
(100%)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/BufferingNoOpRequestIndexer.java
(95%)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/ElasticsearchApiCallBridge.java
(96%)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/ElasticsearchSinkBase.java
(96%)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/ElasticsearchSinkFunction.java
(91%)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/RequestIndexer.java
(99%)
copy inlong-sort/sort-flink/{sort-flink-v1.13 =>
sort-flink-v1.15}/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/AbstractTimeIndexGenerator.java
(100%)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/ElasticsearchConfiguration.java
(79%)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/ElasticsearchConnectorOptions.java
(99%)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/ElasticsearchValidationUtils.java
(98%)
copy inlong-sort/sort-flink/{sort-flink-v1.13 =>
sort-flink-v1.15}/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/IndexGenerator.java
(99%)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/IndexGeneratorBase.java
(100%)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/IndexGeneratorFactory.java
(99%)
copy inlong-sort/sort-flink/{sort-flink-v1.13 =>
sort-flink-v1.15}/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/KeyExtractor.java
(100%)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/RequestFactory.java
(97%)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/RowElasticsearchSinkFunction.java
(94%)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/StaticIndexGenerator.java
(95%)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/util/IgnoringFailureHandler.java
(96%)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/util/NoOpFailureHandler.java
(97%)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/util/RetryRejectedExecutionFailureHandler.java
(100%)
