increased input buffer size

influxdata · Jul 10, 2019 · 03bf644 · 03bf644
1 parent 86902eb
commit 03bf644
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cmd/bulk_load_influx/main.go b/cmd/bulk_load_influx/main.go
@@ -486,7 +486,7 @@ func scan(itemsPerBatch int, doneCh chan int) (int64, int64, int64) {
 
 	var batchItemCount uint64
 
-	scanner := bufio.NewScanner(bufio.NewReaderSize(os.Stdin, 4*1024*1024))
+	scanner := bufio.NewScanner(bufio.NewReaderSize(os.Stdin, 16*1024*1024))
 outer:
 	for scanner.Scan() {
 		if itemsRead == itemLimit {