Fix pathological case triggering quadratic runtime for merging sorted…

… lists
m3db · Jun 2, 2017 · 60d2e41 · 60d2e41
1 parent 05ee6a1
commit 60d2e41
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/aggregation/quantile/cm/stream.go b/aggregation/quantile/cm/stream.go
@@ -250,7 +250,7 @@ func (s *stream) insert() {
 		return
 	}
 
-	for s.bufMore.Len() > 0 && s.bufMore.Min() > s.samples.Back().value {
+	for s.bufMore.Len() > 0 && s.bufMore.Min() >= s.samples.Back().value {
 		sample := s.acquireSampleFn()
 		sample.setData(s.bufMore.Pop(), 1, 0)
 		s.samples.PushBack(sample)