Merge pull request #839 from payonxp/master

Debug Memory Leak
2026-11-04 00:30:15 +08:00 · 2018-08-14 16:39:41 +08:00
parent 15526aab8c c8a32b578c
commit feb2af060f
1 changed files with 1 additions and 1 deletions
--- a/store/src/main/java/com/alibaba/otter/canal/store/memory/MemoryEventStoreWithBuffer.java
+++ b/store/src/main/java/com/alibaba/otter/canal/store/memory/MemoryEventStoreWithBuffer.java
@@ -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
                        }
                    }