fixed batchSize calc

2026-11-04 00:30:15 +08:00 · 2018-11-24 15:34:39 +08:00
parent ec235f3efd
commit 29f03bf398
1 changed files with 2 additions and 2 deletions
--- 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;
        }
    }