dont call getinstance twice in checkpointing (#6516)

Signed-off-by: Owen Diehl <ow.diehl@gmail.com>
pull/6518/head
Owen Diehl 3 years ago committed by GitHub
parent 6a9557a1e0
commit 8eed9a4dde
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 2
      pkg/ingester/checkpoint.go

@ -207,7 +207,7 @@ type streamIterator struct {
func newStreamsIterator(ing ingesterInstances) *streamIterator {
instances := ing.getInstances()
streamInstances := make([]streamInstance, len(instances))
for i, inst := range ing.getInstances() {
for i, inst := range instances {
streams := make([]*stream, 0, inst.streams.Len())
_ = inst.forAllStreams(context.Background(), func(s *stream) error {
streams = append(streams, s)

Loading…
Cancel
Save