# Logstash error while processing ingest node pipeline

**URL:** <https://discuss.elastic.co/t/logstash-error-while-processing-ingest-node-pipeline/105606>\
**Category:** Elasticsearch\
**Created:** [October 27, 2017, 7:28pm UTC](https://discuss.elastic.co/t/logstash-error-while-processing-ingest-node-pipeline/105606 "2017-10-27T19:28:17Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![Pratiksha\_Tewary](https://avatars.discourse-cdn.com/v4/letter/p/a88e4f/32.png) [@Pratiksha\_Tewary](https://discuss.elastic.co/u/Pratiksha_Tewary)\
**Post date:** [October 27, 2017, 7:28pm UTC](https://discuss.elastic.co/t/logstash-error-while-processing-ingest-node-pipeline/105606/1 "2017-10-27T19:28:17Z")

</div>

Hi,  
I am trying to implement a pipeline in logstash which takes data from a source, does a small field extraction using grok filter (divides the event into **field 1** and **rest** ). My output segment in the logstash config is of the following format:

elasticsearch  
{  
hosts =\> "[http://127.0.0.1:9200/](http://127.0.0.1:9200/)"  
index =\> "\<index\_name\>"  
document\_type =\> "\<mapping\_type\>"  
pipeline =\> "\< **pipeline\_name** \>"  
user =\> "elastic"  
password =\> "changeme"  
workers =\> 1  
}

Now, there are 10 different values possible for **field 1**. Based on the value of **field 1** , the **pipeline\_name** will change (so basically, I have created 10 different ingest node pipelines in my elasticsearch instance as well.

When I try to implement this, I get the following error in Windows Powershell:

```
[2017-10-27T15:02:52,538][INFO][logstash.outputs.elasticsearch] Retrying individual bulk actions that failed or were rejected by the previous bulk request. {:count=>1}
[2017-10-27T15:02:54,548][INFO][logstash.outputs.elasticsearch] retrying failed action with response code: 500 ({"type"=>"exception", "reason"=>"java.lang.IllegalArgumentException: java.lang.IllegalArgumentExce
ption: field[rest] size [40] doesn't match header size [6].", "caused_by"=>{"type"=>"illegal_argument_exception", "reason"=>"java.lang.IllegalArgumentException: field[rest] size [40] doesn't match header size [6
].", "caused_by"=>{"type"=>"illegal_argument_exception", "reason"=>"field[rest] size [40] doesn't match header size [6]."}}, "header"=>{"processor_type"=>"csv"}})

```

I am not being able to decipher this error. Any help would be appreciated.

Thanks.

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [November 24, 2017, 7:28pm UTC](https://discuss.elastic.co/t/logstash-error-while-processing-ingest-node-pipeline/105606/2 "2017-11-24T19:28:24Z")

</div>

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.