This is an automated email from the ASF dual-hosted git repository.
wanghailin pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from adb656e298 [Hotfix][Zeta][Log] Fix zeta parallelStream log trace for
job (#8456)
add a4a38ccff2 [Feature][Elasticsearch] Support sink ddl (#8412)
No new revisions were added by this update.
Summary of changes:
docs/en/concept/schema-evolution.md | 1 +
docs/en/connector-v2/sink/Elasticsearch.md | 43 ++++-
docs/zh/concept/schema-evolution.md | 1 +
docs/zh/connector-v2/sink/Elasticsearch.md | 43 ++++-
.../elasticsearch/client/EsRestClient.java | 78 +++++++-
.../exception/ElasticsearchConnectorErrorCode.java | 4 +-
.../elasticsearch/sink/ElasticsearchSink.java | 12 +-
.../sink/ElasticsearchSinkWriter.java | 42 ++++-
.../connector-elasticsearch-e2e/pom.xml | 32 ++++
.../elasticsearch/ElasticsearchSchemaChangeIT.java | 209 +++++++++++++++++++++
.../src/test/resources/ddl/add_columns.sql} | 26 +--
.../src/test/resources/ddl/shop.sql | 2 -
.../src/test/resources/docker/server-gtids/my.cnf | 0
.../src/test/resources/docker/setup.sql | 0
...qlcdc_to_elasticsearch_with_schema_change.conf} | 36 ++--
15 files changed, 481 insertions(+), 48 deletions(-)
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-elasticsearch-e2e/src/test/java/org/apache/seatunnel/e2e/connector/elasticsearch/ElasticsearchSchemaChangeIT.java
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-doris-e2e/src/test/resources/ddl/modify_columns.sql
=> connector-elasticsearch-e2e/src/test/resources/ddl/add_columns.sql} (56%)
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-doris-e2e =>
connector-elasticsearch-e2e}/src/test/resources/ddl/shop.sql (95%)
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-cdc-mysql-e2e =>
connector-elasticsearch-e2e}/src/test/resources/docker/server-gtids/my.cnf
(100%)
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-doris-e2e =>
connector-elasticsearch-e2e}/src/test/resources/docker/setup.sql (100%)
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-doris-e2e/src/test/resources/mysqlcdc_to_doris_with_schema_change.conf
=>
connector-elasticsearch-e2e/src/test/resources/elasticsearch/mysqlcdc_to_elasticsearch_with_schema_change.conf}
(72%)
