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%)