fix compress

pingcap · Aug 17, 2022 · 10ee044 · 10ee044
1 parent fe97732
commit 10ee044
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/drainer/util.go b/drainer/util.go
@@ -43,7 +43,7 @@ import (
 
 const (
 	maxKafkaMsgSize = 1 << 30
-	maxGrpcMsgSize  = int(^uint(0) >> 1)
+	maxGrpcMsgSize  = int(^uint(0)>>1) - 4*1024*1024 // max grpc message size, leave 4MB as buffer, see https://github.com/pingcap/tidb-binlog/issues/1152
 )
 
 // taskGroup is a wrapper of `sync.WaitGroup`.

diff --git a/pump/config.go b/pump/config.go
@@ -35,7 +35,7 @@ const (
 	defaultEtcdDialTimeout   = 5 * time.Second
 	defaultEtcdURLs          = "http://127.0.0.1:2379"
 	defaultListenAddr        = "127.0.0.1:8250"
-	defaultMaxMsgSize        = int(^uint(0) >> 1) // max grpc message size
+	defaultMaxMsgSize        = int(^uint(0)>>1) - 4*1024*1024 // max grpc message size, leave 4MB as buffer, see https://github.com/pingcap/tidb-binlog/issues/1152
 	defaultHeartbeatInterval = 2
 	defaultGC                = "7"
 	defaultDataDir           = "data.pump"