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