diff --git a/dbsync/src/test/java/com/taobao/tddl/dbsync/FetcherPerformanceTest.java b/dbsync/src/test/java/com/taobao/tddl/dbsync/FetcherPerformanceTest.java index 03fedccd..f5af66e3 100644 --- a/dbsync/src/test/java/com/taobao/tddl/dbsync/FetcherPerformanceTest.java +++ b/dbsync/src/test/java/com/taobao/tddl/dbsync/FetcherPerformanceTest.java @@ -7,8 +7,6 @@ import java.sql.Statement; import java.util.concurrent.atomic.AtomicLong; import com.taobao.tddl.dbsync.binlog.DirectLogFetcher; -import com.taobao.tddl.dbsync.binlog.LogContext; -import com.taobao.tddl.dbsync.binlog.LogDecoder; import com.taobao.tddl.dbsync.binlog.LogEvent; public class FetcherPerformanceTest { @@ -31,10 +29,7 @@ public class FetcherPerformanceTest { long last = 0; long end = 0; - LogDecoder decoder = new LogDecoder(LogEvent.UNKNOWN_EVENT, LogEvent.ENUM_END_EVENT); - LogContext context = new LogContext(); while (fetcher.fetch()) { - decoder.decode(fetcher, context); sum.incrementAndGet(); long current = sum.get(); if (current - last >= 100000) {