From 88de747ed54cf3b550eb1c225f772c743f10b637 Mon Sep 17 00:00:00 2001
From: Chuanyi Li <chuanyili0625@gmail.com>
Date: Wed, 8 Aug 2018 07:53:44 +0800
Subject: [PATCH] Improve sink blocking time resolution.

---
 .../java/com/alibaba/otter/canal/sink/entry/EntryEventSink.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 699b06a5..7afde6b6 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
@@ -164,7 +164,7 @@ public class EntryEventSink extends AbstractCanalEventSink<List<CanalEntry.Entry
                     blockingStart = System.nanoTime();
                 }
                 applyWait(++fullTimes);
-                if (fullTimes % 1000 == 0) {
+                if (fullTimes % 100 == 0) {
                     long nextStart = System.nanoTime();
                     eventsSinkBlockingTime.addAndGet(nextStart - blockingStart);
                     blockingStart = nextStart;