Skip to content

filebeat issues using ingest pipeline #2229

@djschny

Description

@djschny
  • Version: v5.0.0-alpha5
  • Operating System: Mac 10.11.15

Startup elsaticsearch and register the following pipeline:

PUT _ingest/pipeline/apachelogs
{
  "description": "Pipeline to parse Apache logs",
  "processors": [
    {
      "grok": {
        "field": "message",
        "patterns": [
          "%{COMBINEDAPACHELOG}"
        ]
      }
    },
    {
      "date": {
        "field": "timestamp",
        "target_field": "timestamp",
        "formats": [
          "dd/MMM/YYYY:HH:mm:ss Z"
        ]
      }
    },
    {
      "convert": {
        "field": "response",
        "type": "integer"
      }
    },
    {
      "convert": {
        "field": "bytes",
        "type": "integer"
      }
    }
  ]
}

Notice it registers successfully and then try to manually use the pipeline with both simulation and indexing and notice the doc indexes successfully with no errors:

POST _ingest/pipeline/apachelogs/_simulate
{
  "docs": [
    {
      "_source": {
        "message": "183.60.215.50 - - [01/Jun/2015:18:00:00 +0000] \"GET /scripts/netcat-webserver HTTP/1.1\" 200 182 \"-\" \"Mozilla/5.0 (compatible; EasouSpider; +http://www.easou.com/search/spider.html)\""
      }
    }
  ]
}

Then use filebeat to ingest data using the pipeline and notice that filebeat will throw errors parsing a bulk error response and on the elasticsearch server side there are errors with the pipeline being thrown.

ElasticsearchException[java.lang.IllegalArgumentException: java.lang.IllegalArgumentException: Provided Grok expressions do not match field value: [    ASL Module "com.apple.eventmonitor" claims selected messages.]]; nested: IllegalArgumentException[java.lang.IllegalArgumentException: Provided Grok expressions do not match field value: [    ASL Module "com.apple.eventmonitor" claims selected messages.]]; nested: IllegalArgumentException[Provided Grok expressions do not match field value: [    ASL Module "com.apple.eventmonitor" claims selected messages.]];
    at org.elasticsearch.ingest.CompoundProcessor.newCompoundProcessorException(CompoundProcessor.java:156)
    at org.elasticsearch.ingest.CompoundProcessor.execute(CompoundProcessor.java:107)
    at org.elasticsearch.ingest.Pipeline.execute(Pipeline.java:52)
    at org.elasticsearch.ingest.PipelineExecutionService.innerExecute(PipelineExecutionService.java:166)
    at org.elasticsearch.ingest.PipelineExecutionService.access$000(PipelineExecutionService.java:41)
    at org.elasticsearch.ingest.PipelineExecutionService$2.doRun(PipelineExecutionService.java:88)
    at org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingAbstractRunnable.doRun(ThreadContext.java:510)
    at org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:37)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: java.lang.IllegalArgumentException: Provided Grok expressions do not match field value: [    ASL Module "com.apple.eventmonitor" claims selected messages.]
    ... 11 more
Caused by: java.lang.IllegalArgumentException: Provided Grok expressions do not match field value: [    ASL Module "com.apple.eventmonitor" claims selected messages.]
    at org.elasticsearch.ingest.common.GrokProcessor.execute(GrokProcessor.java:59)
    at org.elasticsearch.ingest.CompoundProcessor.execute(CompoundProcessor.java:100

Beats side of things:

2016/08/10 21:13:56.942025 client.go:381: ERR Failed to parse bulk response item: expected end of object

Full set of example logs can be found at https://s3.amazonaws.com/elk-workshop.elasticsearch.org/source/logs.gz

Assigning to @urso but was also working with @andrewkroh as well.

Metadata

Metadata

Assignees

Labels

Type

No type
No fields configured for issues without a type.

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions