Elasticsearch通过哈希映射将文档均匀地路由到分片中,同时shard均匀地分散在各个数据节点中,这样可能会出现某些节点存储的热点数据较多,导致这些节点的负载较高的情况。针对这种情况,可采用重启集群或手动迁移shard的方式,重新分配shard,临时降低高负载节点的压力。本文介绍如何手动迁移shard。

问题场景

  • 负载高的节点中存在大量的同一属性分片,例如仅存在主分片。
  • 业务索引在负载高的节点存储的shard比其他节点多。

注意事项

  • 手动迁移shard,仅能临时解决节点压力较高的问题。如果节点短暂地脱离集群,shard重新分配,这些节点可能还会出现同样的问题。因此建议在迁移shard前,参见集群负载不均问题的分析方法及解决方案,优化shard后再迁移。
  • 如果热点索引分配均衡,而集群整体压力较大,建议升配集群或扩容节点,解决资源紧张的问题。

解决方案

  1. 禁用分片分配。
    PUT /_cluster/settings
    {
      "transient" : {
         "cluster.routing.allocation.enable" : "none"
      }
    }
    注意 以上命令仅临时禁用了分片分配,shard迁移完成后,需要重新启用(将 cluster.routing.allocation.enable设置为 all)。
  2. 手动迁移shard。
    以下示例将 index_parkingorder_v1索引,从 192.168.130.77节点上的3号分片迁移到 192.168.130.78节点上。
    POST /_cluster/reroute
    {
     "commands" : [
      {
       "move" : {
        "index" : "index_parkingorder_v1", 
        "shard" : 3,
        "from_node" : "192.168.130.77", 
        "to_node" : "192.168.130.78"
       }
      }
     ]
    }
    说明
    • 迁移shard时,请确保同一序号的shard不能迁移到同一节点。例如,A节点中已经存在某一索引的3号副本分片,那么该索引的3号主分片就不能迁移到A节点中。
    • 手动迁移shard更详细的说明,请参见cluster-reroute
  3. 查看shard迁移状态。
    GET _cat/shards?v
    正常情况下,返回结果如下。 查看shard迁移过程
  4. shard迁移完成后,重新启用分片分配。
    PUT /_cluster/settings
    {
     "transient" : {
      "cluster.routing.allocation.enable" : "all"
     }
    }