Failed to execute pipeline for a bulk

Elastic Stack Elasticsearch
1

I got the message, 'failed to execute pipeline for a bulk' .

The detail is

[2017-02-16T18:34:44,121][ERROR][o.e.a.b.TransportBulkAction] [cr-node-1] failed to execute pipeline for a bulk request
org.elasticsearch.common.util.concurrent.EsRejectedExecutionException: rejected execution of org.elasticsearch.ingest.PipelineExecutionService$2@e249f5e on EsThreadPoolExecutor[bulk, queue capacity = 50, org.elasticsearch.common.util.concurrent.EsThreadPoolExecutor@157c3366[Running, pool size = 4, active threads = 4, queued tasks = 55, completed tasks = 924376]]
        at org.elasticsearch.common.util.concurrent.EsAbortPolicy.rejectedExecution(EsAbortPolicy.java:50) ~[elasticsearch-5.2.0.jar:5.2.0]
        at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:823) ~[?:1.8.0_73]
        at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1369) ~[?:1.8.0_73]
 at org.elasticsearch.common.util.concurrent.EsThreadPoolExecutor.doExecute(EsThreadPoolExecutor.java:94) ~[elasticsearch-5.2.0.jar:5.2.0]
    at org.elasticsearch.common.util.concurrent.EsThreadPoolExecutor.execute(EsThreadPoolExecutor.java:89) ~[elasticsearch-5.2.0.jar:5.2.0]
    at org.elasticsearch.ingest.PipelineExecutionService.executeBulkRequest(PipelineExecutionService.java:74) ~[elasticsearch-5.2.0.jar:5.2.0]
    at org.elasticsearch.action.bulk.TransportBulkAction.processBulkIndexIngestRequest(TransportBulkAction.java:487) ~[elasticsearch-5.2.0.jar:5.2.0]
    at org.elasticsearch.action.bulk.TransportBulkAction.doExecute(TransportBulkAction.java:133) ~[elasticsearch-5.2.0.jar:5.2.0]
    at org.elasticsearch.action.bulk.TransportBulkAction.doExecute(TransportBulkAction.java:82) ~[elasticsearch-5.2.0.jar:5.2.0]
    at org.elasticsearch.action.support.TransportAction$RequestFilterChain.proceed(TransportAction.java:173) ~[elasticsearch-5.2.0.jar:5.2.0]
    at org.elasticsearch.xpack.security.action.filter.SecurityActionFilter.lambda$apply$1(SecurityActionFilter.java:127) ~[?:?]
    at org.elasticsearch.action.ActionListener$1.onResponse(ActionListener.java:56) ~[elasticsearch-5.2.0.jar:5.2.0]
    at org.elasticsearch.xpack.security.action.filter.SecurityActionFilter.lambda$authorizeRequest$4(SecurityActionFilter.java:202) ~[?:?]
    at org.elasticsearch.xpack.security.authz.AuthorizationUtils$AsyncAuthorizer.maybeRun(AuthorizationUtils.java:127) ~[?:?]            ...

I used the stack with filebeat, logstash, elasticsearch and x-pack. And the message 'retrying failed action with response code: 429 ' with this error was occurred in the logstash.
How could I resolve this problem?

1 Like
2

We get the same error with elasticsearch 5.2 and x-pack version. But we don't have an idea how to solve the problem. Have you found a solution meanwhile?

Found this issue: frequent-error-message

3

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