You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by zh...@apache.org on 2022/07/11 05:52:34 UTC
[rocketmq-connect] branch master updated: Clean up duplicate methods (#184)
This is an automated email from the ASF dual-hosted git repository.
zhoubo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
The following commit(s) were added to refs/heads/master by this push:
new c6598db Clean up duplicate methods (#184)
c6598db is described below
commit c6598db63e21da4764646d2072a6e513dc63a04a
Author: yhx-coder <46...@users.noreply.github.com>
AuthorDate: Mon Jul 11 13:52:30 2022 +0800
Clean up duplicate methods (#184)
---
.../rocketmq/connect/runtime/connectorwrapper/WorkerDirectTask.java | 1 -
1 file changed, 1 deletion(-)
diff --git a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerDirectTask.java b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerDirectTask.java
index 3387a80..9c2b7d1 100644
--- a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerDirectTask.java
+++ b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerDirectTask.java
@@ -179,7 +179,6 @@ public class WorkerDirectTask implements WorkerTask {
return taskConfig;
}
-
@Override
public void resetOffset(RecordPartition recordPartition, RecordOffset recordOffset) {