debug memory leak

2018-08-14 15:59:08 +08:00
parent 84f3d92790
commit c8a32b578c
1 changed files with 1 additions and 1 deletions
@@ -417,7 +417,7 @@ public class MemoryEventStoreWithBuffer extends AbstractCanalStoreScavenge imple
                    if (batchMode.isMemSize()) {
                        ackMemSize.addAndGet(memsize);
                        // 尝试清空buffer中的内存，将ack之前的内存全部释放掉
-                        for (long index = sequence + 1; index < next; index++) {
+                        for (long index = sequence + 1; index <= next; index++) {
                            entries[getIndex(index)] = null;// 设置为null
                        }
                    }