You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@inlong.apache.org by do...@apache.org on 2022/03/02 13:15:28 UTC

[incubator-inlong] branch master updated (b4dbd82 -> 6c65ad4)

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.


    from b4dbd82  [INLONG-2832][docker] package the docker resource to the distribution file (#2833)
     add 6c65ad4  [INLONG-2821][Manager] Change the status of the source after receiving the task snapshot (#2835)

No new revisions were added by this update.

Summary of changes:
 .../inlong/manager/common/enums/Constant.java      |   2 +
 .../inlong/manager/common/enums/SourceState.java   | 127 +++++++++++++++++----
 .../dao/mapper/StreamSourceEntityMapper.java       |  20 +++-
 .../mappers/InlongStreamFieldEntityMapper.xml      |   6 +-
 .../resources/mappers/StreamSourceEntityMapper.xml |  23 +++-
 .../service/core/impl/InlongGroupServiceImpl.java  |   4 +-
 .../source/AbstractStreamSourceOperation.java      |  29 +++--
 .../service/source/SourceSnapshotOperation.java    |  94 ++++++++++++++-
 .../service/source/StreamSourceOperation.java      |   3 +-
 .../service/source/StreamSourceService.java        |  21 ++++
 .../service/source/StreamSourceServiceImpl.java    |  60 ++++++----
 .../listener/AbstractSourceOperateListener.java    |  11 +-
 .../source/listener/DataSourceListenerTest.java    |  36 ++++--
 .../service/workflow/WorkflowServiceImplTest.java  |  56 +++++++--
 .../org/apache/inlong/manager/test/BaseTest.java   |   7 +-
 .../inlong/manager/workflow/WorkflowContext.java   |   6 +-
 16 files changed, 400 insertions(+), 105 deletions(-)