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 9301823 [INLONG-2224][DataProxy] Source receive one message will be
send to pulsar twice when config both memery channel and file channel (#2257)
add 7188718 [INLONG-2229] Support pulsar anthentication in Manager and
Sort (#2249)
No new revisions were added by this update.
Summary of changes:
inlong-dataproxy/README.md | 2 +-
.../manager/common/settings/BusinessSettings.java | 21 ++---
.../manager/dao/entity/BusinessExtEntity.java | 2 +-
inlong-manager/manager-service/pom.xml | 12 +++
.../mq/CreatePulsarGroupForStreamTaskListener.java | 4 +-
.../mq/CreatePulsarGroupTaskListener.java | 4 +-
.../mq/CreatePulsarResourceTaskListener.java | 5 +-
.../mq/CreatePulsarTopicForStreamTaskListener.java | 5 +-
.../service/thirdpart/mq/util/PulsarUtils.java | 49 ++++++++++++
.../thirdpart/sort/PushHiveConfigTaskListener.java | 78 +++++++++++++------
.../ConsumptionCompleteProcessListener.java | 30 +++----
.../{workflow/business => core}/BaseConfig.java | 2 +-
.../{workflow/business => core}/BaseTest.java | 2 +-
.../service/core/impl/BusinessServiceImplTest.java | 67 ++++++++++++++++
.../service/thirdpart/mq/util/PulsarUtilsTest.java | 91 ++++++++++++++++++++++
.../CreateBusinessWorkflowDefinitionTest.java | 1 +
.../src/test/resources/application-test.properties | 30 +++----
.../sort/protocol/source/PulsarSourceInfo.java | 14 +++-
.../sort/protocol/source/PulsarSourceInfoTest.java | 67 ++++++++++++++++
.../pulsar/MultiTopicPulsarSourceFunction.java | 1 +
.../sort/flink/pulsar/PulsarSourceFunction.java | 11 ++-
.../inlong/sort/flink/pulsar/PulsarUtils.java | 25 +++++-
.../flink/pulsar/PulsarTestMetaManagerUtil.java | 5 +-
23 files changed, 441 insertions(+), 87 deletions(-)
copy
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/http/Context.java
=>
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/settings/BusinessSettings.java
(64%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/{workflow/business
=> core}/BaseConfig.java (94%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/{workflow/business
=> core}/BaseTest.java (96%)
create mode 100644
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/impl/BusinessServiceImplTest.java
create mode 100644
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/thirdpart/mq/util/PulsarUtilsTest.java
create mode 100644
inlong-sort/sort-common/src/test/java/org/apache/inlong/sort/protocol/source/PulsarSourceInfoTest.java
