Details
-
Improvement
-
Resolution: Unresolved
-
Major
-
7.6.0
-
0
Description
In orderCopyAndMoveTransferTokens, rebalancer is using "rebalance.transferBatchSize" config but it should ideally read the transfer batch size based on the scheduling version.
If schedulingVersion is >= v2 (i.e. per node transfer batching is enabled), then the config:
"indexer.rebalance.perNodeTransferBatchSize" has to be picked up
func (sr *ShardRebalancer) orderCopyAndMoveTransferTokens() {
|
cfg := sr.config.Load()
|
windowSz := cfg["rebalance.transferBatchSize"].Int()
|
if windowSz == 0 {
|
sr.batchedTokens = []map[string]*c.TransferToken{sr.transferTokens}
|
return
|
}
|