chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

Improve sink blocking time resolution.

Browse Source
This commit is contained in:
Chuanyi Li
2018-08-08 07:53:44 +08:00
parent 179afb0340
commit dfd58f4aa1
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
sink/src/main/java/com/alibaba/otter/canal/sink/entry/EntryEventSink.java
View File

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