[rocketmq-streams] branch main updated: can not compile

[du...@apache.org]

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

duhengforever pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git


The following commit(s) were added to refs/heads/main by this push:
     new 2b528fb  can not compile
     new 854dde3  Merge pull request #26 from ni-ze/main
2b528fb is described below

commit 2b528fb31a12ac31ab54d62bf7baeb26b539ba61
Author: 倪泽 <ni...@alibaba-inc.com>
AuthorDate: Sat Aug 21 17:39:41 2021 +0800

    can not compile
---
 .../rocketmq/streams/common/channel/AbstractChannel.java       | 10 ----------
 1 file changed, 10 deletions(-)

diff --git a/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/AbstractChannel.java b/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/AbstractChannel.java
index 035a99d..f5ff47e 100644
--- a/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/AbstractChannel.java
+++ b/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/AbstractChannel.java
@@ -94,16 +94,6 @@ public abstract class AbstractChannel extends BasedConfigurable implements IChan
     }
 
     @Override
-    public void removeSplit(Set<String> splitIds) {
-        source.removeSplit(splitIds);
-    }
-
-    @Override
-    public void addNewSplit(Set<String> splitIds) {
-        source.addNewSplit(splitIds);
-    }
-
-    @Override
     public Map<String, MessageOffset> getFinishedQueueIdAndOffsets(CheckPointMessage checkPointMessage) {
         return sink.getFinishedQueueIdAndOffsets(checkPointMessage);
     }