From 006dd6364689da592109b8e1e0946e1184beb21a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BE=90=E5=BB=BA=E6=B5=B7?= <1723262513@qq.com> Date: Thu, 6 Oct 2016 15:48:05 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=8D=E5=A5=BD=E7=9A=84=E8=AE=BE=E8=AE=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../otter/canal/parse/inbound/AbstractEventParser.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/AbstractEventParser.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/AbstractEventParser.java index 9e8c10ab..00f149be 100644 --- a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/AbstractEventParser.java +++ b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/AbstractEventParser.java @@ -388,7 +388,10 @@ public abstract class AbstractEventParser extends AbstractCanalLifeCycle String name = String.format("destination = %s , address = %s , HeartBeatTimeTask", destination, runningInfo == null ? null : runningInfo.getAddress().toString()); - synchronized (MysqlEventParser.class) { +// synchronized(AbstractEventParser.class){ +// synchronized (MysqlEventParser.class) { +// why use MysqlEventParser.class, u know, MysqlEventParser is the child class 4 AbstractEventParser, +// do this is ... if (timer == null) { timer = new Timer(name, true); }