From 29f03bf398ae0dcaf4a2ce26a243332192c05443 Mon Sep 17 00:00:00 2001 From: agapple Date: Sat, 24 Nov 2018 15:34:39 +0800 Subject: [PATCH] fixed batchSize calc --- .../main/java/com/alibaba/otter/canal/store/model/Event.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/store/src/main/java/com/alibaba/otter/canal/store/model/Event.java b/store/src/main/java/com/alibaba/otter/canal/store/model/Event.java index edb4dd24..db1618e1 100644 --- a/store/src/main/java/com/alibaba/otter/canal/store/model/Event.java +++ b/store/src/main/java/com/alibaba/otter/canal/store/model/Event.java @@ -71,8 +71,8 @@ public class Event implements Serializable { this.rawLength = rawEntry.size(); } else { this.entry = entry; - // 按照3倍的event length预估 - this.rawLength = entry.getHeader().getEventLength() * 3; + // 按照6倍的event length预估 + this.rawLength = entry.getHeader().getEventLength() * 6; } }