فهرست منبع

Merge pull request #1118 from littleneko/patch-1

fix: buildLastTransactionPosition 的 for 循环少了 =0
agapple 6 سال پیش
والد
کامیت
041225c3f2
1فایلهای تغییر یافته به همراه1 افزوده شده و 1 حذف شده
  1. 1 1
      parse/src/main/java/com/alibaba/otter/canal/parse/inbound/AbstractEventParser.java

+ 1 - 1
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/AbstractEventParser.java

@@ -417,7 +417,7 @@ public abstract class AbstractEventParser<EVENT> extends AbstractCanalLifeCycle
     }
 
     protected LogPosition buildLastTransactionPosition(List<CanalEntry.Entry> 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);