diff --git a/client/internal/netflow/store/event_aggregation_test.go b/client/internal/netflow/store/event_aggregation_test.go index c0422e8b7..2406290ef 100644 --- a/client/internal/netflow/store/event_aggregation_test.go +++ b/client/internal/netflow/store/event_aggregation_test.go @@ -176,6 +176,10 @@ func TestFlowAggregationOfUnknownProtocols(t *testing.T) { func TestResetAggregationWindow(t *testing.T) { store := NewAggregatingMemoryStore() + // Backdate the window start: the reset below happens within the OS + // clock granularity (~15ms on Windows), which would otherwise make + // the old and new window start timestamps identical. + store.WindowStart = store.WindowStart.Add(-time.Second) store.StoreEvent(&types.Event{ ID: uuid.New(), Timestamp: time.Now(),