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