More logs

pkg/dedup/iter.go

@@ -195,6 +195,7 @@ type dedupSeries struct {
 }
 
 func newDedupSeries(lset labels.Labels, replicas []storage.Series, f string) *dedupSeries {
+	debug("dedup for a counter? %v", isCounter(f))
 	return &dedupSeries{lset: lset, isCounter: isCounter(f), replicas: replicas, f: f}
 }
 
@@ -203,17 +204,18 @@ func (s *dedupSeries) Labels() labels.Labels {
 }
 
 func (s *dedupSeries) Iterator(_ chunkenc.Iterator) chunkenc.Iterator {
+	debug("Iterator() of length %v", len(s.replicas))
 	var it adjustableSeriesIterator
 	if s.isCounter {
-		it = &counterErrAdjustSeriesIterator{Iterator: s.replicas[0].Iterator(nil)}
+		it = newCounterErrAdjustSeriesIterator(s.replicas[0].Iterator(nil))
 	} else {
 		it = noopAdjustableSeriesIterator{Iterator: s.replicas[0].Iterator(nil)}
 	}
 
 	for _, o := range s.replicas[1:] {
 		var replicaIter adjustableSeriesIterator
 		if s.isCounter {
-			replicaIter = &counterErrAdjustSeriesIterator{Iterator: o.Iterator(nil)}
+			replicaIter = newCounterErrAdjustSeriesIterator(o.Iterator(nil))
 		} else {
 			replicaIter = noopAdjustableSeriesIterator{Iterator: o.Iterator(nil)}
 		}
@@ -265,6 +267,15 @@ type counterErrAdjustSeriesIterator struct {
 	chunkenc.Iterator
 
 	errAdjust float64
+
+	id int
+}
+
+var gId int
+
+func newCounterErrAdjustSeriesIterator(itr chunkenc.Iterator) *counterErrAdjustSeriesIterator {
+	gId++
+	return &counterErrAdjustSeriesIterator{Iterator: itr, id: gId}
 }
 
 func (it *counterErrAdjustSeriesIterator) adjustAtValue(lastFloatValue float64) {
@@ -277,6 +288,7 @@ func (it *counterErrAdjustSeriesIterator) adjustAtValue(lastFloatValue float64)
 
 func (it *counterErrAdjustSeriesIterator) At() (int64, float64) {
 	t, v := it.Iterator.At()
+	debug(" one replica original value #%d: %v %v", it.id, t/1000, v)
 	return t, v + it.errAdjust
 }
 

pkg/query/iter.go

@@ -4,6 +4,8 @@
 package query
 
 import (
+	"fmt"
+
 	"github.com/pkg/errors"
 	"github.com/prometheus/prometheus/model/histogram"
 	"github.com/prometheus/prometheus/model/labels"
@@ -46,8 +48,8 @@ func (s *promSeriesSet) At() storage.Series {
 	if s.set.Err() != nil {
 		return nil
 	}
-
 	currLset, currChunks := s.set.At()
+	fmt.Printf("merge_itr: promSeriesSet.At() %v %v %v %v %v %v\n", currLset.Hash(), currLset, currChunks, s.mint, s.maxt, s.aggrs)
 	return newChunkSeries(currLset, currChunks, s.mint, s.maxt, s.aggrs)
 }
 
@@ -83,6 +85,7 @@ func (*storeSeriesSet) Err() error {
 }
 
 func (s *storeSeriesSet) At() (labels.Labels, []storepb.AggrChunk) {
+	fmt.Printf("merge_itr: storeSeriesSet.At() %v %v\n", s.series[s.i].Labels, s.series[s.i].Chunks)
 	return s.series[s.i].PromLabels(), s.series[s.i].Chunks
 }