From ac4970ef3af144b2de95c8cbd09557642bd9acd7 Mon Sep 17 00:00:00 2001 From: agapple Date: Wed, 17 Dec 2014 22:08:36 +0800 Subject: [PATCH] fixed issue #105 , seek method add format eventType parse --- .../otter/canal/parse/inbound/mysql/MysqlConnection.java | 2 +- 1 file changed, 1 insertion(+), 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 840b9875..08b330a6 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 @@ -84,6 +84,7 @@ public class MysqlConnection implements ErosaConnection { fetcher.start(connector.getChannel()); LogDecoder decoder = new LogDecoder(); decoder.handle(LogEvent.ROTATE_EVENT); + decoder.handle(LogEvent.FORMAT_DESCRIPTION_EVENT); decoder.handle(LogEvent.QUERY_EVENT); decoder.handle(LogEvent.XID_EVENT); LogContext context = new LogContext(); @@ -202,7 +203,6 @@ public class MysqlConnection implements ErosaConnection { logger.warn(ExceptionUtils.getFullStackTrace(e)); } - try { // mariadb针对特殊的类型，需要设置session变量 update("SET @mariadb_slave_capability='" + LogEvent.MARIA_SLAVE_CAPABILITY_MINE + "'");