Final changes

harry671003 · Oct 25, 2023 · bb01419 · bb01419
1 parent 3bfe370
commit bb01419
Showing 1 changed file with 11 additions and 4 deletions.
diff --git a/pkg/querier/blocks_store_queryable.go b/pkg/querier/blocks_store_queryable.go
@@ -731,21 +731,28 @@ func (q *blocksStoreQuerier) fetchSeriesFromStores(
 
 			myQueriedBlocks = append(myQueriedBlocks, blockID)
 			numSeries := len(mySeries)
+
+			level.Info(spanLog).Log("msg", "received series from index-gateway",
+				"instance", c.RemoteAddress(),
+				"requested blocks", blockID.String(),
+				"queried blocks", strings.Join(convertULIDsToString(myQueriedBlocks), " "),
+				"found series", len(mySeries),
+			)
+
 			chunks, err := q.fetchChunksFromStore(gCtx, userID, blockID, mySeries)
 			if err != nil {
 				return err
 			}
 
-			reqStats.AddFetchedSeries(uint64(numSeries))
-
-			level.Info(spanLog).Log("msg", "received series from store-gateway",
+			level.Info(spanLog).Log("msg", "received chunks from chunks-gateway",
 				"instance", c.RemoteAddress(),
 				"requested blocks", blockID.String(),
 				"queried blocks", strings.Join(convertULIDsToString(myQueriedBlocks), " "),
-				"found series", len(mySeries),
 				"found chunks", len(chunks),
 			)
 
+			reqStats.AddFetchedSeries(uint64(numSeries))
+
 			// Store the result.
 			mtx.Lock()
 			if len(mySeries) > 0 {