[incubator-inlong] branch master updated (391aee6 -> bdc0459)

[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 391aee6  [INLONG-2816][BUG][Sort-sdk]fix the OOM ERROR of InLongTopicManagerImplTest (#2817)
     add bdc0459  [INLONG-2815][Manager] Optimize Inlong domains for manager-client (#2825)

No new revisions were added by this update.

Summary of changes:
 .../inlong/manager/client/api/InlongGroup.java     | 13 ++--
 ...nlongGroupInfo.java => InlongGroupContext.java} |  8 +-
 .../manager/client/api/impl/BlankInlongGroup.java  | 14 ++--
 .../api/impl/DefaultInlongStreamBuilder.java       |  2 +-
 .../manager/client/api/impl/InlongClientImpl.java  | 14 ++--
 .../manager/client/api/impl/InlongGroupImpl.java   | 86 ++++++++++++----------
 .../client/api/inner/InnerGroupContext.java        |  8 +-
 .../client/api/inner/InnerInlongManagerClient.java | 15 ++--
 .../client/api/util/InlongGroupTransfer.java       | 51 ++++++-------
 .../manager/client/api/util/InlongParser.java      |  6 +-
 .../client/api/util/InlongStreamTransfer.java      | 10 +--
 ...nlongGroupRequest.java => InlongGroupInfo.java} | 26 ++++---
 .../common/pojo/group/InlongGroupRequest.java      |  7 +-
 ...gGroupRequest.java => InlongGroupResponse.java} | 23 ++----
 .../workflow/form/GroupResourceProcessForm.java    | 11 ++-
 .../pojo/workflow/form/NewGroupProcessForm.java    |  9 +--
 .../pojo/workflow/form/UpdateGroupProcessForm.java |  4 +-
 .../manager/service/core/ConsumptionService.java   |  4 +-
 .../manager/service/core/InlongGroupService.java   |  3 +-
 .../service/core/impl/ConsumptionServiceImpl.java  | 23 +++---
 .../core/impl/InlongGroupProcessOperation.java     | 24 +++---
 .../service/core/impl/InlongGroupServiceImpl.java  |  7 +-
 .../service/sink/StreamSinkServiceImpl.java        | 25 +++----
 .../listener/AbstractSourceOperateListener.java    |  8 +-
 .../mq/CreatePulsarGroupForStreamTaskListener.java |  7 +-
 .../mq/CreatePulsarGroupTaskListener.java          |  4 +-
 .../mq/CreatePulsarResourceTaskListener.java       |  9 +--
 .../mq/CreatePulsarTopicForStreamTaskListener.java |  9 +--
 .../thirdparty/mq/CreateTubeGroupTaskListener.java |  4 +-
 .../thirdparty/mq/CreateTubeTopicTaskListener.java |  4 +-
 .../service/thirdparty/mq/TubeEventSelector.java   |  6 +-
 .../service/thirdparty/mq/util/PulsarUtils.java    |  7 +-
 .../thirdparty/sort/CreateSortConfigListener.java  | 56 +++++++-------
 .../thirdparty/sort/PushSortConfigListener.java    | 13 ++--
 .../thirdparty/sort/ZkDisabledEventSelector.java   |  6 +-
 .../thirdparty/sort/ZkEnabledEventSelector.java    |  6 +-
 .../thirdparty/sort/util/SourceInfoUtils.java      | 13 ++--
 .../NewConsumptionWorkflowDefinition.java          | 11 ++-
 .../ConsumptionCompleteProcessListener.java        | 15 ++--
 .../listener/GroupCompleteProcessListener.java     |  6 +-
 .../workflow/group/listener/InitGroupListener.java |  4 +-
 .../listener/UpdateGroupCompleteListener.java      |  6 +-
 .../group/listener/UpdateGroupListener.java        |  4 +-
 .../stream/InitGroupForStreamListener.java         |  4 +-
 .../core/impl/InlongGroupProcessOperationTest.java | 13 ++--
 .../service/core/impl/InlongGroupServiceTest.java  | 13 ++--
 .../source/listener/DataSourceListenerTest.java    | 24 +++---
 .../hive/CreateHiveTableEventSelectorTest.java     |  6 +-
 .../thirdparty/mq/util/PulsarUtilsTest.java        |  4 +-
 .../thirdparty/sort/DisableZkForSortTest.java      | 28 +++----
 .../workflow/ServiceTaskListenerFactoryTest.java   |  7 +-
 .../service/workflow/WorkflowServiceImplTest.java  | 36 ++++-----
 .../web/controller/InlongGroupController.java      |  5 +-
 53 files changed, 365 insertions(+), 366 deletions(-)
 rename inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/{InlongGroupInfo.java => InlongGroupContext.java} (90%)
 copy inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/group/{InlongGroupRequest.java => InlongGroupInfo.java} (89%)
 copy inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/group/{InlongGroupRequest.java => InlongGroupResponse.java} (92%)