You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by go...@apache.org on 2022/03/18 13:49:22 UTC
[incubator-inlong] branch master updated (1510444 -> 3f5e7a0)
This is an automated email from the ASF dual-hosted git repository.
gosonzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.
from 1510444 [INLONG-3228][Manager] Deadlock found when trying to get lock in getting stream source (#3229)
add 3f5e7a0 [INLONG-3222][Manager] Check source state when operate in delete / restart / stop(#3230)
No new revisions were added by this update.
Summary of changes:
.../pojo/workflow/form/UpdateGroupProcessForm.java | 2 +-
.../dao/mapper/StreamSourceEntityMapper.java | 2 +
.../resources/mappers/StreamSourceEntityMapper.xml | 7 ++-
.../source/AbstractStreamSourceOperation.java | 2 +-
.../listener/AbstractSourceOperateListener.java | 70 ++++++++++++++++++++--
.../group/DeleteGroupWorkflowDefinition.java | 4 ++
.../group/RestartGroupWorkflowDefinition.java | 5 ++
.../group/SuspendGroupWorkflowDefinition.java | 5 ++
...istener.java => UpdateGroupFailedListener.java} | 25 ++------
9 files changed, 93 insertions(+), 29 deletions(-)
copy inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/group/listener/{UpdateGroupCompleteListener.java => UpdateGroupFailedListener.java} (72%)