diff --git a/lib/streamaggr/streamaggr_test.go b/lib/streamaggr/streamaggr_test.go index aa32bfda4..5090ee31c 100644 --- a/lib/streamaggr/streamaggr_test.go +++ b/lib/streamaggr/streamaggr_test.go @@ -251,32 +251,6 @@ func TestAggregatorsSuccess(t *testing.T) { } } - // rate with duplicated events - f(` -- interval: 1m - by: [cde] - outputs: [rate_sum, rate_avg] -`, ` -foo{abc="123", cde="1"} 0 10 -foo{abc="123", cde="1"} 0 10 -`, `foo:1m_by_cde_rate_avg{cde="1"} 0 -foo:1m_by_cde_rate_sum{cde="1"} 0 -`, "11") - - // rate with duplicated events - f(` -- interval: 1m - by: [cde] - outputs: [rate_sum, rate_avg] -`, ` -foo{abc="123", cde="1"} -4 10 -foo{abc="123", cde="1"} -2 20 -`, `foo:1m_by_cde_rate_avg{cde="1"} 0 -foo:1m_by_cde_rate_sum{cde="1"} 0 -`, "11") - - return - // Empty config f(``, ``, ``, "") f(``, `foo{bar="baz"} 1`, ``, "0")