You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ki...@apache.org on 2022/09/23 11:08:40 UTC
[incubator-seatunnel] branch dev updated (e568bcf9e -> 2fcbbf464)
This is an automated email from the ASF dual-hosted git repository.
kirs pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
from e568bcf9e [DEV][DOC] Add some hints to the mysql documentation (#2855)
add 2fcbbf464 [Connector-V2] [ElasticSearch] Fix ElasticSearch Connector V2 Bug (#2817)
No new revisions were added by this update.
Summary of changes:
docs/en/connector-v2/sink/Elasticsearch.md | 19 ++++++++++---------
.../common/source/AbstractSingleSplitSource.java | 2 +-
.../connector-elasticsearch/pom.xml | 6 ++++++
.../seatunnel/elasticsearch/client/EsRestClient.java | 0
.../seatunnel/elasticsearch/config/SinkConfig.java | 0
.../seatunnel/elasticsearch/constant/BulkConfig.java | 0
.../elasticsearch/constant/ElasticsearchVersion.java | 0
.../seatunnel/elasticsearch/dto/BulkResponse.java | 0
.../seatunnel/elasticsearch/dto/IndexInfo.java | 0
.../exception/BulkElasticsearchException.java | 0
.../exception/GetElasticsearchVersionException.java | 0
.../serialize/ElasticsearchRowSerializer.java | 9 ++++++---
.../serialize/SeaTunnelRowSerializer.java | 0
.../serialize/index/IndexSerializer.java | 0
.../serialize/index/IndexSerializerFactory.java | 0
.../index/impl/FixedValueIndexSerializer.java | 0
.../serialize/index/impl/VariableIndexSerializer.java | 0
.../serialize/type/IndexTypeSerializer.java | 0
.../serialize/type/IndexTypeSerializerFactory.java | 0
.../serialize/type/impl/NotIndexTypeSerializer.java | 0
.../type/impl/RequiredIndexTypeSerializer.java | 0
.../elasticsearch/sink/ElasticsearchSink.java | 0
.../elasticsearch/sink/ElasticsearchSinkWriter.java | 4 ++--
.../state/ElasticsearchAggregatedCommitInfo.java | 0
.../elasticsearch/state/ElasticsearchCommitInfo.java | 0
.../elasticsearch/state/ElasticsearchSinkState.java | 0
.../seatunnel/elasticsearch/util/RegexUtils.java | 0
.../seatunnel/fake/source/FakeRandomData.java | 2 +-
.../FakeRandomDataTest.java | 2 +-
29 files changed, 27 insertions(+), 17 deletions(-)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/client/EsRestClient.java (100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/config/SinkConfig.java (100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/constant/BulkConfig.java (100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/constant/ElasticsearchVersion.java (100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/dto/BulkResponse.java (100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/dto/IndexInfo.java (100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/exception/BulkElasticsearchException.java (100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/exception/GetElasticsearchVersionException.java (100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/ElasticsearchRowSerializer.java (92%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/SeaTunnelRowSerializer.java (100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/index/IndexSerializer.java (100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/index/IndexSerializerFactory.java (100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/index/impl/FixedValueIndexSerializer.java (100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/index/impl/VariableIndexSerializer.java (100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/type/IndexTypeSerializer.java (100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/type/IndexTypeSerializerFactory.java (100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/type/impl/NotIndexTypeSerializer.java (100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/type/impl/RequiredIndexTypeSerializer.java (100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink/ElasticsearchSink.java (100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink/ElasticsearchSinkWriter.java (98%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/state/ElasticsearchAggregatedCommitInfo.java (100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/state/ElasticsearchCommitInfo.java (100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/state/ElasticsearchSinkState.java (100%)
rename seatunnel-connectors-v2/connector-elasticsearch/src/{ => main}/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/util/RegexUtils.java (100%)