fixed issue #868 , NPE fixed

This commit is contained in:
七锋
2018-09-04 11:28:56 +08:00
parent d4a70d5eea
commit 47ac10ca18

View File

@@ -435,7 +435,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
}
}