log addtl info about bytes/shard in planning (#6573)

Signed-off-by: Owen Diehl <ow.diehl@gmail.com>
pull/6561/head
Owen Diehl 3 years ago committed by GitHub
parent 7314d95a91
commit 2e348218e2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 5
      pkg/querier/queryrange/shard_resolver.go

@ -120,6 +120,10 @@ func (r *dynamicShardResolver) Shards(e syntax.Expr) (int, error) {
combined := stats.MergeStats(results...)
factor := guessShardFactor(combined, r.maxParallelism)
var bytesPerShard = combined.Bytes
if factor > 0 {
bytesPerShard = combined.Bytes / uint64(factor)
}
level.Debug(sp).Log(
"msg", "queried index",
"type", "combined",
@ -131,6 +135,7 @@ func (r *dynamicShardResolver) Shards(e syntax.Expr) (int, error) {
"max_parallelism", r.maxParallelism,
"duration", time.Since(start),
"factor", factor,
"bytes_per_shard", strings.Replace(humanize.Bytes(bytesPerShard), " ", "", 1),
)
return factor, nil
}

Loading…
Cancel
Save