diff --git a/internal/querycoord/index_checker.go b/internal/querycoord/index_checker.go index 560ba75017..532e05f5bf 100644 --- a/internal/querycoord/index_checker.go +++ b/internal/querycoord/index_checker.go @@ -110,6 +110,7 @@ func (ic *IndexChecker) close() { ic.wg.Wait() } +// reloadFromKV reload collection/partition, remove from etcd if failed. func (ic *IndexChecker) reloadFromKV() error { _, handoffReqValues, version, err := ic.client.LoadWithRevision(handoffSegmentPrefix) if err != nil {