From eef58005d9cf5f3035ccfcf2915770e9610aa29d Mon Sep 17 00:00:00 2001 From: agapple Date: Thu, 12 Jan 2017 11:31:43 +0800 Subject: [PATCH] fixed format --- .../otter/canal/parse/inbound/mysql/MysqlConnection.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 8d5eeae9..40408bfa 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 @@ -282,7 +282,8 @@ public class MysqlConnection implements ErosaConnection { } List columnValues = rs.getFieldValues(); - if (columnValues != null && columnValues.size() >= 1 && columnValues.get(0)!=null && columnValues.get(0).toUpperCase().equals("CRC32")) { + if (columnValues != null && columnValues.size() >= 1 && columnValues.get(0) != null + && columnValues.get(0).toUpperCase().equals("CRC32")) { binlogChecksum = LogEvent.BINLOG_CHECKSUM_ALG_CRC32; } else { binlogChecksum = LogEvent.BINLOG_CHECKSUM_ALG_OFF;