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/02/24 02:43:33 UTC

[incubator-inlong] branch master updated (ff27e05 -> 9d0479c)

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 ff27e05  [INLONG-2660][Manager] Optimize inlong group state control (#2673)
     add 9d0479c  [INLONG-2669][Manager] Optimizing inlong-manager source module code structure (#2669)

No new revisions were added by this update.

Summary of changes:
 .../source/AbstractStreamSourceOperation.java      | 103 ++++++++++++++++++++
 .../service/source/StreamSourceOperation.java      |   5 +-
 .../service/source/StreamSourceServiceImpl.java    |   2 +-
 .../source/binlog/BinlogStreamSourceOperation.java | 105 +++++----------------
 .../source/kafka/KafkaStreamSourceOperation.java   |  98 +++++--------------
 5 files changed, 154 insertions(+), 159 deletions(-)
 create mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/AbstractStreamSourceOperation.java