REBALANCELEADERS

根據活動節(jié)點上的preferredLeader屬性重新分配集合中的leader。

/admin/collections?action=REBALANCELEADERS&collection=collectionName

根據活動節(jié)點上的preferredLeader屬性將leader分配到一個集合中。在通過BALANCESHARDUNIQUE或ADDREPLICAPROP命令分配preferredLeader屬性之后，應執(zhí)行此命令。

并不要求集合中的所有碎片都有preferredLeader屬性。再平衡將只嘗試重新分配領導那些將preferredLeader屬性設置為true 的副本，而不是當前的碎片leader和當前的活動狀態(tài)。

REBALANCELEADERS參數(shù)

• collection
  

  要重新平衡的集合的名稱preferredLeaders。該參數(shù)是必需的。

• maxAtOnce
  

  一次排隊的最大重新分配數(shù)量。值<= 0使用默認值Integer.MAX_VALUE。

  當達到這個數(shù)字時，該過程等待一個或多個領導者被成功分配，然后再增加更多的隊列。

• maxWaitSeconds
  

  默認為60。這是等待領導人重新分配時的超時值。如果maxAtOnce小于將要發(fā)生的重新分配的數(shù)量，則這是任何一次等待至少一次重新分配的最大間隔。

  例如，如果10和再分配是發(fā)生和maxAtOnce是1與maxWaitSeconds是60，在該命令可以等待的時間的上限是10分鐘。

REBALANCELEADERS響應

響應將包括請求的狀態(tài)。如果狀態(tài)不是“0”，則會顯示一條錯誤消息，說明請求失敗的原因。

使用REBALANCELEADERS的例子

在這個例子中輸入：

這些命令中的任何一個都會導致所有具有preferredLeader屬性設置的活動副本，并且不是已經成為首選的leader。

http://localhost:8983/solr/admin/collections?action=REBALANCELEADERS&collection=collection1
http://localhost:8983/solr/admin/collections?action=REBALANCELEADERS&collection=collection1&maxAtOnce=5&maxWaitSeconds=30

得到輸出：

在這個例子中，“alreadyLeaders”部分中的兩個副本已經將leader分配給與該preferredLeader屬性相同的節(jié)點，因此沒有采取任何操作。

“inactivePreferreds”部分中的副本具有preferredLeader屬性集，但節(jié)點已關閉且不采取任何操作?！皊uccesses”部分的三個節(jié)點是leader，因為他們擁有preferredLeader屬性集，但不是leader，他們是活躍的。

<response>
  <lst name="responseHeader">
    <int name="status">0</int>
    <int name="QTime">123</int>
  </lst>
  <lst name="alreadyLeaders">
    <lst name="core_node1">
      <str name="status">success</str>
      <str name="msg">Already leader</str>
      <str name="nodeName">192.168.1.167:7400_solr</str>
    </lst>
    <lst name="core_node17">
      <str name="status">success</str>
      <str name="msg">Already leader</str>
      <str name="nodeName">192.168.1.167:7600_solr</str>
    </lst>
  </lst>
  <lst name="inactivePreferreds">
    <lst name="core_node4">
      <str name="status">skipped</str>
      <str name="msg">Node is a referredLeader, but it's inactive. Skipping</str>
      <str name="nodeName">192.168.1.167:7500_solr</str>
    </lst>
  </lst>
  <lst name="successes">
    <lst name="_collection1_shard3_replica1">
      <str name="status">success</str>
      <str name="msg">
        Assigned 'Collection: 'collection1', Shard: 'shard3', Core: 'collection1_shard3_replica1', BaseUrl:
        'http://192.168.1.167:8983/solr'' to be leader
      </str>
    </lst>
    <lst name="_collection1_shard5_replica3">
      <str name="status">success</str>
      <str name="msg">
        Assigned 'Collection: 'collection1', Shard: 'shard5', Core: 'collection1_shard5_replica3', BaseUrl:
        'http://192.168.1.167:7200/solr'' to be leader
      </str>
    </lst>
    <lst name="_collection1_shard4_replica2">
      <str name="status">success</str>
      <str name="msg">
        Assigned 'Collection: 'collection1', Shard: 'shard4', Core: 'collection1_shard4_replica2', BaseUrl:
        'http://192.168.1.167:7300/solr'' to be leader
      </str>
    </lst>
  </lst>
</response>

發(fā)出這個調用之后檢查clustertate應該顯示每個擁有該preferredLeader屬性的活動節(jié)點，也應該將“l(fā)eader”屬性設置為true。