fix code check fail: not ovride removeSplit() and addNewSplit()

Author: tigerweili

rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/AbstractChannel.java

@@ -93,6 +93,16 @@ protected void setJsonObject(JSONObject jsonObject) {
         jsonObject.put("source", Base64Utils.encode(InstantiationUtil.serializeObject(source)));
     }
 
+    @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);