0
点赞
收藏
分享

微信扫一扫

【Elasticsearch】聚合查询(四)

菜头粿子园 2023-09-29 阅读 41

报错:

使用logstash导入分片数量为9的index发生错误,

[logstash.outputs.elasticsearch] retrying failed action with response code: 429 
({"type"=>"es_rejected_execution_exception", "reason"=>"rejected execution of processing of [12373521]
[indices:data/write/bulk[s][p]]: request: 
BulkShardRequest [[suricatadns140][97]] containing [2] requests, 
target allocation id: -erjXlg0RjeETfZKXokiiQ, 
primary term: 1 on EsThreadPoolExecutor[name = node-1/write, queue capacity = 200, 
org.elasticsearch.common.util.concurrent.EsThreadPoolExecutor@139538e0[Running, 
pool size = 8, active threads = 8, queued tasks = 200, completed tasks = 179152]]"})

原因:

因为导入的数据和ES写入的数据速度不匹配,ES为了保护自己,产生了拒绝

解决:

在ES的配置yml文件中添加:

thread_pool.write.queue_size: 10000
举报

相关推荐

0 条评论