# \[Logstash\] - Exception in Pipelineworker **URL:** \ **Category:** Logstash\ **Created:** [October 25, 2017, 8:05am UTC](https://discuss.elastic.co/t/logstash-exception-in-pipelineworker/105191 "2017-10-25T08:05:40Z")\ **Posts on this page:** 5\ **Page:** 1
**Author:** ![azam](https://avatars.discourse-cdn.com/v4/letter/a/ea666f/32.png) [@azam](https://discuss.elastic.co/u/azam)\ **Post date:** [October 25, 2017, 8:05am UTC](https://discuss.elastic.co/t/logstash-exception-in-pipelineworker/105191/1 "2017-10-25T08:05:40Z")
Hi everyone I am a new user to ELK stack. I tried to setup elastic stack on my local machine but logstash doesn't work for me. I tried to debug, it showed an error "Exception in pipelineworker". Please help ! My logstash configuration are following: input { file{ path =\> "/Users/aztahir/Downloads/data/cars.csv" start\_position =\> "beginning" sincedb\_path =\> "/dev/null" } } filter { csv { ``` separator => "," columns => [ "maker", "model", "mileage", "manufacture_year", "engine_displacement", "engine_power", "body_type", "color_slug", "stk_year", "transmission", "door_count", "seat_count", "fuel_type", "date_created", "date_last_seen", "price_eur" ] } mutate {convert => ["mileage", "integer"] } mutate {convert => ["price_eur", "float"] } mutate {convert => ["engine_power", "integer"] } mutate {convert => ["door_count", "integer"] } mutate {convert => ["seat_count", "integer"] } ``` } output{ elasticsearch { hosts =\> "localhost" index =\> "cars" document\_type =\> "sold\_cars" } stdout {} } [2017-10-25T09:47:03,770][DEBUG][logstash.outputs.stdout] config LogStash::Outputs::Stdout/@workers = 1 [2017-10-25T09:47:03,770][DEBUG][logstash.agent] starting agent [2017-10-25T09:47:03,770][DEBUG][logstash.agent] starting pipeline {:id=\>"main"} [2017-10-25T09:47:03,786][DEBUG][logstash.outputs.elasticsearch] Normalizing http path {:path=\>nil, :normalized=\>nil} [2017-10-25T09:47:04,004][INFO][logstash.outputs.elasticsearch] Elasticsearch pool URLs updated {:changes=\>{:removed=\>[], :added=\>[[http://localhost:9200/](http://localhost:9200/)]}} [2017-10-25T09:47:04,004][INFO][logstash.outputs.elasticsearch] Running health check to see if an Elasticsearch connection is working {:healthcheck\_url=\>[http://localhost:9200/](http://localhost:9200/), :path=\>"/"} [2017-10-25T09:47:04,087][WARN][logstash.outputs.elasticsearch] Restored connection to ES instance {:url=\>"[http://localhost:9200/](http://localhost:9200/)"} [2017-10-25T09:47:04,165][INFO][logstash.outputs.elasticsearch] Using mapping template from {:path=\>nil} [2017-10-25T09:47:04,165][INFO][logstash.outputs.elasticsearch] Attempting to install template {:manage\_template=\>{"template"=\>"logstash-_", "version"=\>50001, "settings"=\>{"index.refresh\_interval"=\>"5s"}, "mappings"=\>{"default"=\>{"\_all"=\>{"enabled"=\>true, "norms"=\>false}, "dynamic\_templates"=\>[{"message\_field"=\>{"path\_match"=\>"message", "match\_mapping\_type"=\>"string", "mapping"=\>{"type"=\>"text", "norms"=\>false}}}, {"string\_fields"=\>{"match"=\>"_", "match\_mapping\_type"=\>"string", "mapping"=\>{"type"=\>"text", "norms"=\>false, "fields"=\>{"keyword"=\>{"type"=\>"keyword", "ignore\_above"=\>256}}}}}], "properties"=\>{"@timestamp"=\>{"type"=\>"date", "include\_in\_all"=\>false}, "@version"=\>{"type"=\>"keyword", "include\_in\_all"=\>false}, "geoip"=\>{"dynamic"=\>true, "properties"=\>{"ip"=\>{"type"=\>"ip"}, "location"=\>{"type"=\>"geo\_point"}, "latitude"=\>{"type"=\>"half\_float"}, "longitude"=\>{"type"=\>"half\_float"}}}}}}}} [2017-10-25T09:47:04,165][DEBUG][logstash.outputs.elasticsearch] Found existing Elasticsearch template. Skipping template management {:name=\>"logstash"} [2017-10-25T09:47:04,165][INFO][logstash.outputs.elasticsearch] New Elasticsearch output {:class=\>"LogStash::Outputs::ElasticSearch", :hosts=\>["[//localhost](https://localhost)"]} [2017-10-25T09:47:04,168][DEBUG][logstash.filters.csv] CSV parsing options {:col\_sep=\>",", :quote\_char=\>"""} [2017-10-25T09:47:04,168][INFO][logstash.pipeline] Starting pipeline {"id"=\>"main", "pipeline.workers"=\>4, "pipeline.batch.size"=\>125, "pipeline.batch.delay"=\>5, "pipeline.max\_inflight"=\>500} [2017-10-25T09:47:04,170][ERROR][logstash.pipeline] Exception in pipelineworker, the pipeline stopped processing new events, please check your filter configuration and restart Logstash. {"exception"=\>"undefined method `to_hash' for []:Array", "backtrace"=>["(eval):190:in`filter\_func'", "C:/Users/aztahir/Downloads/ELK-Stack/Logstash-5.6.3/logstash-core/lib/logstash/pipeline.rb:398:in `filter_batch'", "C:/Users/aztahir/Downloads/ELK-Stack/Logstash-5.6.3/logstash-core/lib/logstash/pipeline.rb:379:in`worker\_loop'", "C:/Users/aztahir/Downloads/ELK-Stack/Logstash-5.6.3/logstash-core/lib/logstash/pipeline.rb:342:in `start_workers'"]} [2017-10-25T09:47:04,204][ERROR][logstash.pipeline] Exception in pipelineworker, the pipeline stopped processing new events, please check your filter configuration and restart Logstash. {"exception"=>"undefined method`to\_hash' for []:Array", "backtrace"=\>["(eval):190:in `filter_func'", "C:/Users/aztahir/Downloads/ELK-Stack/Logstash-5.6.3/logstash-core/lib/logstash/pipeline.rb:398:in`filter\_batch'", "C:/Users/aztahir/Downloads/ELK-Stack/Logstash-5.6.3/logstash-core/lib/logstash/pipeline.rb:379:in `worker_loop'", "C:/Users/aztahir/Downloads/ELK-Stack/Logstash-5.6.3/logstash-core/lib/logstash/pipeline.rb:342:in`start\_workers'"]} [FATAL] 2017-10-25 09:47:04.204 [LogStash::Runner] runner - An unexpected error occurred! {:error=\>#\, :backtrace=>["(eval):190:in`filter\_func'", "C:/Users/aztahir/Downloads/ELK-Stack/Logstash-5.6.3/logstash-core/lib/logstash/pipeline.rb:398:in `filter_batch'", "C:/Users/aztahir/Downloads/ELK-Stack/Logstash-5.6.3/logstash-core/lib/logstash/pipeline.rb:379:in`worker\_loop'", "C:/Users/aztahir/Downloads/ELK-Stack/Logstash-5.6.3/logstash-core/lib/logstash/pipeline.rb:342:in `start_workers'"]} The signal INT is in use by the JVM and will not work correctly on this platform [2017-10-25T09:47:04,220][ERROR][logstash.pipeline] Exception in pipelineworker, the pipeline stopped processing new events, please check your filter configuration and restart Logstash. {"exception"=>"undefined method`to\_hash' for []:Array", "backtrace"=\>["(eval):190:in `filter_func'", "C:/Users/aztahir/Downloads/ELK-Stack/Logstash-5.6.3/logstash-core/lib/logstash/pipeline.rb:398:in`filter\_batch'", "C:/Users/aztahir/Downloads/ELK-Stack/Logstash-5.6.3/logstash-core/lib/logstash/pipeline.rb:379:in `worker_loop'", "C:/Users/aztahir/Downloads/ELK-Stack/Logstash-5.6.3/logstash-core/lib/logstash/pipeline.rb:342:in`start\_workers'"]} ---
**Author:** ![magnusbaeck](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/magnusbaeck/32/44943_2.png) [@magnusbaeck](https://discuss.elastic.co/u/magnusbaeck)\ **Post date:** [October 25, 2017, 8:46am UTC](https://discuss.elastic.co/t/logstash-exception-in-pipelineworker/105191/2 "2017-10-25T08:46:46Z")
See this topic: > [@NoMethodError: "undefined method 'to\_hash'" with CSV input in Logstash 5.6.2](https://discuss.elastic.co/t/nomethoderror-undefined-method-to-hash-with-csv-input-in-logstash-5-6-2/103545): > > I'm trying to send data from a .csv file containing JMeter results to an online Elasticsearch instance. My .conf file looks this way: input { file { path =\> ["\path\to\somefile.csv"] start\_position =\> "beginning" sincedb\_path =\> "NUL" ignore\_older =\> 0 } } output { elasticsearch { hosts =\> ["my.elasticsearch.instance"] index =\> "jmeter-%{+YYYY.MM.dd}" } stdout { codec =\> rubydebug } } When I run Logstash with the debug option, I get the following error and no da… ---
**Author:** ![azam](https://avatars.discourse-cdn.com/v4/letter/a/ea666f/32.png) [@azam](https://discuss.elastic.co/u/azam)\ **Post date:** [October 25, 2017, 12:23pm UTC](https://discuss.elastic.co/t/logstash-exception-in-pipelineworker/105191/3 "2017-10-25T12:23:19Z")
Hi Magnus Thank you for your support. Problem is fixed for me now. Kibana is up and running locally. ---
**Author:** ![kanishkmehta](https://avatars.discourse-cdn.com/v4/letter/k/13edae/32.png) [@kanishkmehta](https://discuss.elastic.co/u/kanishkmehta)\ **Post date:** [November 11, 2017, 9:51pm UTC](https://discuss.elastic.co/t/logstash-exception-in-pipelineworker/105191/4 "2017-11-11T21:51:11Z")
Hi Azam, I have the exact same issue that you're facing. How did you resolve this issue. Please help. Thank you in advance.. Kanishk ---
**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\ **Post date:** [December 9, 2017, 9:51pm UTC](https://discuss.elastic.co/t/logstash-exception-in-pipelineworker/105191/5 "2017-12-09T21:51:13Z")
This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.