[incubator-inlong] branch master updated (9301823 -> 7188718)

[he...@apache.org]

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