This is an automated email from the ASF dual-hosted git repository.
github-merge-queue[bot] pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from a0213fb6ed [Fix][Connector-V2] Restore legacy RabbitMQ checkpoint
state (#11872)
add b66e0d4802 [Fix][Connector-V2] Add opt-in collision-safe Elasticsearch
IDs (#13003)
No new revisions were added by this update.
Summary of changes:
docs/en/connectors/sink/Elasticsearch.md | 7 +
docs/zh/connectors/sink/Elasticsearch.md | 7 +
.../config/ElasticsearchSinkOptions.java | 7 +
.../elasticsearch}/config/KeyEncoding.java | 4 +-
.../seatunnel/elasticsearch/dto/IndexInfo.java | 3 +
.../serialize/ElasticsearchRowSerializer.java | 5 +-
.../elasticsearch/serialize/KeyExtractor.java | 28 +++-
.../sink/ElasticsearchSinkFactory.java | 2 +
.../elasticsearch/serialize/KeyExtractorTest.java | 150 +++++++++++++++++++++
.../connector/elasticsearch/ElasticsearchIT.java | 23 ++++
.../elasticsearch_composite_key_encoding.conf} | 8 +-
11 files changed, 233 insertions(+), 11 deletions(-)
copy
seatunnel-connectors-v2/{connector-easysearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/easysearch
=>
connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch}/config/KeyEncoding.java
(79%)
create mode 100644
seatunnel-connectors-v2/connector-elasticsearch/src/test/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/KeyExtractorTest.java
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-easysearch-e2e/src/test/resources/easysearch/easysearch_composite_key_encoding.conf
=>
connector-elasticsearch-e2e/src/test/resources/elasticsearch/elasticsearch_composite_key_encoding.conf}
(91%)
