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); }