From 2278340c7b8453e2521bad6bed0b4a82017d47b0 Mon Sep 17 00:00:00 2001 From: littleneko Date: Wed, 7 Nov 2018 20:24:38 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20buildLastTransactionPosition=20=E7=9A=84?= =?UTF-8?q?=20for=20=E5=BE=AA=E7=8E=AF=E5=B0=91=E4=BA=86=20=3D0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../alibaba/otter/canal/parse/inbound/AbstractEventParser.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/AbstractEventParser.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/AbstractEventParser.java index 8902c05e..4d5cf7ec 100644 --- a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/AbstractEventParser.java +++ b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/AbstractEventParser.java @@ -417,7 +417,7 @@ public abstract class AbstractEventParser extends AbstractCanalLifeCycle } protected LogPosition buildLastTransactionPosition(List entries) { // 初始化一下 - for (int i = entries.size() - 1; i > 0; i--) { + for (int i = entries.size() - 1; i >= 0; i--) { CanalEntry.Entry entry = entries.get(i); if (entry.getEntryType() == CanalEntry.EntryType.TRANSACTIONEND) {// 尽量记录一个事务做为position return buildLastPosition(entry);