From c99b4b8cd1cae7613aea9491e72762e6c879cdcf Mon Sep 17 00:00:00 2001 From: agapple Date: Wed, 7 Sep 2016 12:37:21 +0800 Subject: [PATCH] fixed NPE #200 --- .../otter/canal/parse/inbound/mysql/MysqlEventParser.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 56446518..548df70c 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 @@ -395,7 +395,7 @@ public class MysqlEventParser extends AbstractMysqlEventParser implements CanalE // binlog定位位点失败,可能有两个原因: // 1. binlog位点被删除 // 2.vip模式的mysql,发生了主备切换,判断一下serverId是否变化,针对这种模式可以发起一次基于时间戳查找合适的binlog位点 - boolean case2 = (standbyInfo.getAddress() == null) + boolean case2 = (standbyInfo == null || standbyInfo.getAddress() == null) && logPosition.getPostion().getServerId() != null && !logPosition.getPostion().getServerId().equals(findServerId(mysqlConnection)); if (case2) {