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
