reverting to original buffer size 4MB

influxdata · Jul 11, 2019 · a96a43b · a96a43b
1 parent 03bf644
commit a96a43b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/cmd/bulk_data_gen/main.go b/cmd/bulk_data_gen/main.go
@@ -146,7 +146,7 @@ func main() {
 		log.Printf("Using config file %s\n", configFile)
 	}
 
-	out := bufio.NewWriterSize(os.Stdout, 16<<20)
+	out := bufio.NewWriterSize(os.Stdout, 4<<20)
 	defer out.Flush()
 
 	var sim common.Simulator

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, 16*1024*1024))
+	scanner := bufio.NewScanner(bufio.NewReaderSize(os.Stdin, 4*1024*1024))
 outer:
 	for scanner.Scan() {
 		if itemsRead == itemLimit {