diff --git a/storage/remote/queue_manager.go b/storage/remote/queue_manager.go index 6319bb31c8..806543f744 100644 --- a/storage/remote/queue_manager.go +++ b/storage/remote/queue_manager.go @@ -1629,6 +1629,9 @@ func (s *shards) populateReducedTimeSeries(pool *lookupPool, batch []timeSeries, case tHistogram: pendingData[nPending].Histograms = append(pendingData[nPending].Histograms, HistogramToHistogramProto(d.timestamp, d.histogram)) nPendingHistograms++ + case tFloatHistogram: + pendingData[nPending].Histograms = append(pendingData[nPending].Histograms, FloatHistogramToHistogramProto(d.timestamp, d.floatHistogram)) + nPendingHistograms++ } } return nPendingSamples, nPendingExemplars, nPendingHistograms