diff --git a/sink/src/main/java/com/alibaba/otter/canal/sink/entry/EntryEventSink.java b/sink/src/main/java/com/alibaba/otter/canal/sink/entry/EntryEventSink.java index d34450ed..27df9074 100644 --- a/sink/src/main/java/com/alibaba/otter/canal/sink/entry/EntryEventSink.java +++ b/sink/src/main/java/com/alibaba/otter/canal/sink/entry/EntryEventSink.java @@ -100,11 +100,12 @@ public class EntryEventSink extends AbstractCanalEventSink emptyTransactionInterval - || lastTransactionCount.incrementAndGet() > emptyTransctionThresold) { + if (lastTransactionCount.incrementAndGet() <= emptyTransctionThresold + && Math.abs(currentTimestamp - lastTransactionTimestamp) <= emptyTransactionInterval) { + continue; + } else { lastTransactionCount.set(0L); lastTransactionTimestamp = currentTimestamp; - continue; } }