From 448fc8bcde787177db5adcc6e26bc5aae1eff4ab Mon Sep 17 00:00:00 2001 From: agapple Date: Sun, 10 Dec 2017 22:27:14 +0800 Subject: [PATCH] fixed issue #440 --- .../canal/parse/inbound/mysql/MysqlEventParser.java | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParser.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParser.java index 65ce2360..a398ea45 100644 --- a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParser.java +++ b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParser.java @@ -761,14 +761,13 @@ public class MysqlEventParser extends AbstractMysqlEventParser implements CanalE Long logposTimestamp = entry.getHeader().getExecuteTime(); Long serverId = entry.getHeader().getServerId(); - if (CanalEntry.EntryType.TRANSACTIONBEGIN.equals(entry.getEntryType()) - || CanalEntry.EntryType.TRANSACTIONEND.equals(entry.getEntryType())) { + if (logger.isDebugEnabled()) { logger.debug("compare exit condition:{},{},{}, startTimestamp={}...", new Object[] { logfilename, logfileoffset, logposTimestamp, startTimestamp }); - // 事务头和尾寻找第一条记录时间戳，如果最小的一条记录都不满足条件，可直接退出 - if (logposTimestamp >= startTimestamp) { - return false; - } + } + // 事务头和尾寻找第一条记录时间戳，如果最小的一条记录都不满足条件，可直接退出 + if (logposTimestamp >= startTimestamp) { + return false; } if (entryPosition == null) {