From 5addd246ac2ebeba8377e57fbbbe3a70d7cd234a Mon Sep 17 00:00:00 2001 From: agapple Date: Sun, 1 Sep 2019 11:20:00 +0800 Subject: [PATCH] fixed unused error --- .../alibaba/otter/canal/example/SimpleCanalClientTest.java | 4 ++-- .../otter/canal/parse/inbound/mysql/MysqlConnection.java | 5 +++-- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/example/src/main/java/com/alibaba/otter/canal/example/SimpleCanalClientTest.java b/example/src/main/java/com/alibaba/otter/canal/example/SimpleCanalClientTest.java index 658a1419..4f33d9f6 100644 --- a/example/src/main/java/com/alibaba/otter/canal/example/SimpleCanalClientTest.java +++ b/example/src/main/java/com/alibaba/otter/canal/example/SimpleCanalClientTest.java @@ -24,8 +24,8 @@ public class SimpleCanalClientTest extends AbstractCanalClientTest { String ip = AddressUtils.getHostIp(); CanalConnector connector = CanalConnectors.newSingleConnector(new InetSocketAddress(ip, 11111), destination, - "", - ""); + "canal", + "canal"); final SimpleCanalClientTest clientTest = new SimpleCanalClientTest(destination); clientTest.setConnector(connector); 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 90950692..ffe8eafd 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 @@ -521,13 +521,14 @@ public class MysqlConnection implements ErosaConnection { try { rs = query("select @@global.binlog_checksum"); 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; } } catch (Throwable e) { - logger.error("", e); + // logger.error("", e); binlogChecksum = LogEvent.BINLOG_CHECKSUM_ALG_OFF; } }