[inlong] branch master updated (c7226e0fa -> bdeb20d2d)

[zi...@apache.org]

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 c7226e0fa [INLONG-7772][Dashboard] Redis sentinel master name normalization in NodeManagement (#7773)
     add bdeb20d2d [INLONG-7581][Sort] Support multiple-sink migration for Elasticsearch (#7712)

No new revisions were added by this update.

Summary of changes:
 .../manager/pojo/sink/es/ElasticsearchSink.java    |   9 ++
 .../manager/pojo/sort/util/LoadNodeUtils.java      |  22 +++-
 .../protocol/node/load/ElasticsearchLoadNode.java  |  22 +++-
 .../protocol/node/load/ElasticSearchNodeTest.java  |   2 +-
 ...a => MultipleRowElasticsearchSinkFunction.java} |  25 +++--
 .../table/Elasticsearch6DynamicSink.java           |  74 ++++++++++---
 .../table/Elasticsearch6DynamicSinkFactory.java    |  19 +++-
 ...a => MultipleRowElasticsearchSinkFunction.java} |  25 +++--
 .../table/Elasticsearch7Configuration.java         |   1 +
 .../table/Elasticsearch7DynamicSink.java           |  77 ++++++++++---
 .../table/Elasticsearch7DynamicSinkFactory.java    |  22 +++-
 .../sort-connectors/elasticsearch-base/pom.xml     |  12 ++-
 .../table/ElasticsearchConfiguration.java          |   4 +
 .../elasticsearch/table/ElasticsearchOptions.java  |   8 ++
 ... => MultipleElasticsearchSinkFunctionBase.java} | 120 ++++++++++++++++-----
 ...IndexGenerator.java => TableSchemaFactory.java} |  25 ++---
 ...ltipleSinkTest.java => ESMultipleSinkTest.java} |  22 ++--
 .../sort/parser/ElasticsearchSqlParseTest.java     |  17 +--
 18 files changed, 391 insertions(+), 115 deletions(-)
 copy inlong-sort/sort-connectors/elasticsearch-6/src/main/java/org/apache/inlong/sort/elasticsearch6/{RowElasticsearchSinkFunction.java => MultipleRowElasticsearchSinkFunction.java} (70%)
 copy inlong-sort/sort-connectors/elasticsearch-7/src/main/java/org/apache/inlong/sort/elasticsearch7/{RowElasticsearchSinkFunction.java => MultipleRowElasticsearchSinkFunction.java} (70%)
 copy inlong-sort/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/{ElasticsearchSinkFunctionBase.java => MultipleElasticsearchSinkFunctionBase.java} (61%)
 copy inlong-sort/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/{IndexGenerator.java => TableSchemaFactory.java} (62%)
 copy inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/{DorisMultipleSinkTest.java => ESMultipleSinkTest.java} (88%)