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