Uploaded image for project: 'Couchbase Server'
  1. Couchbase Server
  2. MB-59411

Add per node based scheduling for shard rebalance

    XMLWordPrintable

Details

    • 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
      	}
      

       

      Attachments

        No reviews matched the request. Check your Options in the drop-down menu of this sections header.

        Activity

          People

            dhruvil.ketanshah Dhruvil Shah
            varun.velamuri Varun Velamuri
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:

              Gerrit Reviews

                There are no open Gerrit changes

                PagerDuty