Skip to content

Commit b5ed9cc

Browse files
author
george pogosyan
committed
Fix e2e test
1 parent 4f96fba commit b5ed9cc

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

e2e/file_es_split/config.yml

+1-1
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ pipelines:
1010
endpoints:
1111
- http://localhost:9200
1212
fatal_on_failed_insert: true
13-
split_enabled: true
13+
split_batch: true
1414
strict: false
1515
index_format: index_name
1616
retry: 1

plugin/output/elasticsearch/README.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -133,7 +133,7 @@ After an insert error, fall with a non-zero exit code or not
133133

134134
<br>
135135

136-
**`split_batches`** *`bool`* *`default=false`*
136+
**`split_batch`** *`bool`* *`default=false`*
137137

138138
Enable split big batches
139139

plugin/output/elasticsearch/elasticsearch.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -174,7 +174,7 @@ type Config struct {
174174
// > @3@4@5@6
175175
// >
176176
// > Enable split big batches
177-
SplitBatches bool `json:"split_batches" default:"false"` // *
177+
SplitBatch bool `json:"split_batch" default:"false"` // *
178178

179179
// > @3@4@5@6
180180
// >
@@ -376,7 +376,7 @@ func (p *Plugin) out(workerData *pipeline.WorkerData, batch *pipeline.Batch) err
376376
var statusCode int
377377
var err error
378378

379-
if p.config.SplitBatches {
379+
if p.config.SplitBatch {
380380
statusCode, err = p.sendSplit(0, eventsCount, data.begin, data.outBuf)
381381
} else {
382382
statusCode, err = p.send(data.outBuf)

0 commit comments

Comments
 (0)