Remove buf per pump

pingcap · Aug 30, 2019 · 3074b3b · 3074b3b
1 parent f9e4589
commit 3074b3b
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/drainer/merge.go b/drainer/merge.go
@@ -178,7 +178,7 @@ func NewMerger(ts int64, strategy string, sources ...MergeSource) *Merger {
 	m := &Merger{
 		latestTS: ts,
 		sources:  make(map[string]MergeSource),
-		output:   make(chan MergeItem, 10),
+		output:   make(chan MergeItem),
 		strategy: mergeStrategy,
 	}
 

diff --git a/drainer/metrics.go b/drainer/metrics.go
@@ -94,7 +94,7 @@ var (
 			Subsystem: "drainer",
 			Name:      "read_binlog_size",
 			Help:      "Bucketed histogram of size of a binlog.",
-			Buckets:   prometheus.ExponentialBuckets(16, 2, 20),
+			Buckets:   prometheus.ExponentialBuckets(16, 2, 25),
 		}, []string{"nodeID"})
 
 	queueSizeGauge = prometheus.NewGaugeVec(

diff --git a/drainer/pump.go b/drainer/pump.go
@@ -18,7 +18,7 @@ import (
 )
 
 const (
-	binlogChanSize = 10
+	binlogChanSize = 0
 )
 
 // Pump holds the connection to a pump node, and keeps the savepoint of binlog last read