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/03/11 03:53:41 UTC

[incubator-inlong] branch master updated (097f02f -> d6b3926)

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 097f02f  [INLONG-3058][DataProxy] Add some configs while creating Pulsar producer
     add d6b3926  [INLONG-3053][Manager] Push sort config failed as the mqExtInfo is null in workflow form (#3057)

No new revisions were added by this update.

Summary of changes:
 .../manager/client/api/impl/InlongGroupImpl.java   |   2 +-
 .../inlong/manager/common/enums/GroupState.java    | 108 ++++++++++-----------
 .../manager/service/CommonOperateService.java      |   2 +-
 .../core/impl/InlongGroupProcessOperation.java     |   6 +-
 .../service/core/impl/InlongGroupServiceImpl.java  |  24 ++---
 .../service/sink/StreamSinkServiceImpl.java        |   2 +-
 .../source/AbstractStreamSourceOperation.java      |   2 +-
 .../service/source/StreamSourceServiceImpl.java    |   2 +-
 .../thirdparty/sort/PushSortConfigListener.java    |  20 +---
 .../group/listener/GroupCancelProcessListener.java |   4 +-
 .../listener/GroupCompleteProcessListener.java     |   2 +-
 .../group/listener/GroupFailedProcessListener.java |   2 +-
 .../group/listener/GroupPassTaskListener.java      |   2 +-
 .../group/listener/GroupRejectProcessListener.java |   4 +-
 .../workflow/group/listener/InitGroupListener.java |   2 +-
 .../listener/UpdateGroupCompleteListener.java      |   6 +-
 .../group/listener/UpdateGroupListener.java        |   9 +-
 .../core/impl/InlongGroupProcessOperationTest.java |  12 +--
 .../source/listener/DataSourceListenerTest.java    |   6 +-
 .../thirdparty/sort/DisableZkForSortTest.java      |   4 +-
 .../service/workflow/WorkflowServiceImplTest.java  |  16 +--
 21 files changed, 110 insertions(+), 127 deletions(-)