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/22 09:37:46 UTC

[incubator-inlong] branch master updated (ba6d871 -> cf3204b)

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 ba6d871  [INLONG-3274][Agent]  Change the task status to failed when the Kafka topic was deleted
     add cf3204b  [INLONG-3293][Manager] Add version controller for stream source (#3295)

No new revisions were added by this update.

Summary of changes:
 .../apache/inlong/agent/db/TestBerkeleyDBImp.java  |   7 +-
 .../org/apache/inlong/agent/db/TestRocksDbImp.java |   7 +-
 .../org/apache/inlong/common/db/CommandEntity.java |   4 +
 .../inlong/common/pojo/agent/DataConfig.java       |   4 +
 .../common/pojo/source/SourceListResponse.java     |   9 +-
 .../manager/common/pojo/source/SourceRequest.java  |   4 +
 .../manager/common/pojo/source/SourceResponse.java |   3 +
 .../manager/dao/entity/StreamSourceEntity.java     |   1 +
 .../dao/mapper/StreamSourceEntityMapper.java       |   6 +-
 .../resources/mappers/StreamSourceEntityMapper.xml | 167 +++------------------
 .../service/core/impl/AgentServiceImpl.java        |  16 +-
 .../source/AbstractStreamSourceOperation.java      |  80 +++++-----
 .../service/source/SourceSnapshotOperation.java    |  50 ++----
 .../service/source/StreamSourceOperation.java      |   3 +-
 .../service/source/StreamSourceServiceImpl.java    |   6 +-
 .../main/resources/sql/apache_inlong_manager.sql   |   5 +-
 .../manager-web/sql/apache_inlong_manager.sql      |   5 +-
 17 files changed, 127 insertions(+), 250 deletions(-)