Browse Source

issues#244

XuehuiHe 8 years ago
parent
commit
a69b69c724

+ 1 - 0
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() {
     protected void stopHeartBeat() {
+        TimerTask heartBeatTimerTask = this.heartBeatTimerTask;
         super.stopHeartBeat();
         super.stopHeartBeat();
 
 
         if (heartBeatTimerTask != null) {
         if (heartBeatTimerTask != null) {