浏览代码

fixed issue #1282 , NPE

agapple 6 年之前
父节点
当前提交
d2e3e19831
共有 1 个文件被更改,包括 1 次插入0 次删除
  1. 1 0
      parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlConnection.java

+ 1 - 0
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlConnection.java

@@ -508,6 +508,7 @@ public class MysqlConnection implements ErosaConnection {
             rs = query("select @@global.binlog_checksum");
             rs = query("select @@global.binlog_checksum");
         } catch (Throwable e) {
         } catch (Throwable e) {
             // ignore
             // ignore
+            return;
         }
         }
 
 
         List<String> columnValues = rs.getFieldValues();
         List<String> columnValues = rs.getFieldValues();