You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by he...@apache.org on 2022/06/07 03:07:08 UTC

[incubator-inlong] branch master updated (5035ab0c9 -> 196569743)

This is an automated email from the ASF dual-hosted git repository.

healchow pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git


    from 5035ab0c9 [INLONG-4544][Dashboard] Pulsar cluster support tenant param (#4545)
     add 196569743 [INLONG-4519][Manager] Add params and load node for Elasticsearch sink (#4525)

No new revisions were added by this update.

Summary of changes:
 .../common/pojo/sink/es/ElasticsearchSink.java     |  9 ++++
 .../common/pojo/sink/es/ElasticsearchSinkDTO.java  | 12 +++++
 .../sink/es/ElasticsearchSinkListResponse.java     |  9 ++++
 .../pojo/sink/es/ElasticsearchSinkRequest.java     |  9 ++++
 .../manager/service/sort/util/LoadNodeUtils.java   | 44 ++++++++++++++++
 ...ava => ElasticsearchStreamSinkServiceTest.java} | 59 ++++++++++++----------
 6 files changed, 114 insertions(+), 28 deletions(-)
 copy inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/sink/{HBaseStreamSinkServiceTest.java => ElasticsearchStreamSinkServiceTest.java} (61%)