Fix e2e test

ozontech · Feb 12, 2025 · 43b55be · 43b55be
1 parent 739074b
commit 43b55be
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/e2e/file_es_split/config.yml b/e2e/file_es_split/config.yml
@@ -10,7 +10,7 @@ pipelines:
       endpoints:
         - http://localhost:9200
       fatal_on_failed_insert: true
-      split_enabled: true
+      split_batch: true
       strict: false
       index_format: index_name
       retry: 1

diff --git a/plugin/output/elasticsearch/README.md b/plugin/output/elasticsearch/README.md
@@ -133,7 +133,7 @@ After an insert error, fall with a non-zero exit code or not
 
 <br>
 
-**`split_batches`** *`bool`* *`default=false`* 
+**`split_batch`** *`bool`* *`default=false`* 
 
 Enable split big batches
 

diff --git a/plugin/output/elasticsearch/elasticsearch.go b/plugin/output/elasticsearch/elasticsearch.go
@@ -174,7 +174,7 @@ type Config struct {
 	// > @3@4@5@6
 	// >
 	// > Enable split big batches
-	SplitBatches bool `json:"split_batches" default:"false"` // *
+	SplitBatch bool `json:"split_batch" default:"false"` // *
 
 	// > @3@4@5@6
 	// >
@@ -376,7 +376,7 @@ func (p *Plugin) out(workerData *pipeline.WorkerData, batch *pipeline.Batch) err
 	var statusCode int
 	var err error
 
-	if p.config.SplitBatches {
+	if p.config.SplitBatch {
 		statusCode, err = p.sendSplit(0, eventsCount, data.begin, data.outBuf)
 	} else {
 		statusCode, err = p.send(data.outBuf)
-Original file line number
+Diff line change
@@ Expand Up @@
     <br>
-    **`split_batches`** *`bool`* *`default=false`*
+    **`split_batch`** *`bool`* *`default=false`*
     Enable split big batches
@@ Expand Down @@