beater: set default flush timeout to 1s

elastic · Oct 5, 2021 · ccadbc8 · ccadbc8
1 parent 79b2244
commit ccadbc8
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/beater/beater.go b/beater/beater.go
@@ -594,6 +594,8 @@ func (s *serverRunner) newFinalBatchProcessor(p *publish.Publisher) (model.Batch
 		FlushInterval time.Duration `config:"flush_interval"`
 		NumWorkers    int           `config:"num_workers"`
 	}
+	esConfig.FlushInterval = time.Second
+
 	if esOutputConfig != nil {
 		esConfig.Config = elasticsearch.DefaultConfig()
 		if err := esOutputConfig.Unpack(&esConfig); err != nil {