Align: do not append points with the same timestamp

grafana · Sep 23, 2021 · 7502922 · 7502922
1 parent 59ce70d
commit 7502922
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/pkg/timeseries/align.go b/pkg/timeseries/align.go
@@ -40,7 +40,12 @@ func (ts TimeSeries) Align(interval time.Duration) TimeSeries {
 			}
 		}
 
-		alignedTs = append(alignedTs, TimePoint{Time: pointFrameTs, Value: point.Value})
+		if len(alignedTs) > 0 && alignedTs[len(alignedTs)-1].Time == pointFrameTs {
+			// Do not append points with the same timestamp
+			alignedTs[len(alignedTs)-1] = TimePoint{Time: pointFrameTs, Value: point.Value}
+		} else {
+			alignedTs = append(alignedTs, TimePoint{Time: pointFrameTs, Value: point.Value})
+		}
 		frameTs = frameTs.Add(interval)
 	}