你的浏览器禁用了JavaScript, 请开启后刷新浏览器获得更好的体验!

Elasticsearch写入速度越来越慢

Elasticsearch | 作者 elasticmsj1 | 发布于2018年05月02日 | 阅读数：13738

用sparkstreaming并行写入es，采用的是bulk接口，20s写入一次，当索引刚建立时速度挺快，耗时大概8到12s，而当大概运行半天后，写入速度下降很多，耗时变为18s以上，有时候甚至超过40s，有大哥哥知道是什么问题吗

          if(bulkRequest.numberOfActions()>0)

          {

            val bulkResponse = bulkRequest.get()

            if (bulkResponse.hasFailures) {

              println("failed processing bulk index requests " + bulkResponse.buildFailureMessage)

            }

          }