From bc7927fe758638afa0af7da3e37a4c6754ce5d85 Mon Sep 17 00:00:00 2001 From: alexwang Date: Thu, 1 Dec 2016 17:39:51 +0800 Subject: [PATCH] fixed issue #227 , fixed Mysql5.1.73 throw NullPointerException --- .../otter/canal/parse/inbound/mysql/MysqlConnection.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlConnection.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlConnection.java index c3c633d0..e3576d70 100644 --- a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlConnection.java +++ b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlConnection.java @@ -279,8 +279,9 @@ public class MysqlConnection implements ErosaConnection { } List columnValues = rs.getFieldValues(); - if(columnValues.get(0).toUpperCase().equals("CRC32")){ - binlogChecksum = LogEvent.BINLOG_CHECKSUM_ALG_CRC32; + if (columnValues.size() > 0 && columnValues.get(0) != null + && columnValues.get(0).toUpperCase().equals("CRC32")) { + binlogChecksum = LogEvent.BINLOG_CHECKSUM_ALG_CRC32; }else{ binlogChecksum = LogEvent.BINLOG_CHECKSUM_ALG_OFF; }