diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParser.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParser.java index 066a377b..e15a7862 100644 --- a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParser.java +++ b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParser.java @@ -180,6 +180,7 @@ public class MysqlEventParser extends AbstractMysqlEventParser implements CanalE } protected void stopHeartBeat() { + TimerTask heartBeatTimerTask = this.heartBeatTimerTask; super.stopHeartBeat(); if (heartBeatTimerTask != null) {