From dd37ff0c07570e62c7993a38ee781a05574354f9 Mon Sep 17 00:00:00 2001 From: Deepkaran Date: Fri, 9 Apr 2021 16:01:50 -0700 Subject: [PATCH] MB-45380 do not use etag in rebalancer/ddl_service_manager rebalancer/ddl_service_manager do not use etag for /getLocalIndexMetadata. It is better to call the rest api explicitly with useETag=false. Change-Id: I340d4dd70c8914122d8abc63a1c33378618d2d06 --- secondary/indexer/ddl_service_manager.go | 2 +- secondary/indexer/rebalancer.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/secondary/indexer/ddl_service_manager.go b/secondary/indexer/ddl_service_manager.go index d9bdb4bf1..b6f618b63 100644 --- a/secondary/indexer/ddl_service_manager.go +++ b/secondary/indexer/ddl_service_manager.go @@ -1754,7 +1754,7 @@ func newMetadataProvider(clusterAddr string, nodes map[service.NodeID]bool, sett addr, err := cinfo.GetServiceAddress(nid, common.INDEX_HTTP_SERVICE) if err == nil { - resp, err := getWithAuth(addr + "/getLocalIndexMetadata") + resp, err := getWithAuth(addr + "/getLocalIndexMetadata?useETag=false") if err != nil { continue } diff --git a/secondary/indexer/rebalancer.go b/secondary/indexer/rebalancer.go index a0d894557..1bb7e2c19 100644 --- a/secondary/indexer/rebalancer.go +++ b/secondary/indexer/rebalancer.go @@ -1660,7 +1660,7 @@ func getLocalStats(addr string, partitioned bool) (*c.Statistics, error) { func getLocalMeta(addr string) (*manager.LocalIndexMetadata, error) { - url := "/getLocalIndexMetadata" + url := "/getLocalIndexMetadata?useETag=false" resp, err := getWithAuth(addr + url) if err != nil { l.Errorf("Rebalancer::getLocalMeta Error getting local metadata %v %v", addr+url, err)