MemoryEventStoreWithBuffer#cleanUntil方法中ackMemSize

最近在阅读canal 1.1.5中MemoryEventStoreWithBuffer源码的时候，发现在累加ackMemSize的值时，累加出现问题；代码中，447行 memsize += calculateSize(event); 应该使用memsize = calculateSize(event)，不然在453行使用ackMemSize.addAndGet(memsize);进行累加的时候，ackMemSize每次都会多加上了上一次累加过的值大小。

for (long next = sequence + 1; next <= maxSequence; next++) { Event event = entries[getIndex(next)]; if (localExecTime == 0 && event.getExecuteTime() > 0) { localExecTime = event.getExecuteTime(); } deltaRows += event.getRowsCount(); memsize += calculateSize(event); if ((seqId < 0 || next == seqId) && CanalEventUtils.checkPosition(event, (LogPosition) position)) { // 找到对应的position，更新ack seq hasMatch = true;

                if (batchMode.isMemSize()) {
                    ackMemSize.addAndGet(memsize);

原提问者GitHub用户411129516