diff --git a/sdks/go/test/integration/primitives/windowinto.go b/sdks/go/test/integration/primitives/windowinto.go index 8e0224aa10a4..2efaf014567b 100644 --- a/sdks/go/test/integration/primitives/windowinto.go +++ b/sdks/go/test/integration/primitives/windowinto.go @@ -374,7 +374,7 @@ func TriggerAfterSynchronizedProcessingTime(s beam.Scope) { con.AddElements(12000, 5.0, 8.0) col := teststream.Create(s, con) - trigger := trigger.Repeat(trigger.AfterSynchronizedProcessingTime()) + trigger := trigger.AfterSynchronizedProcessingTime() windowSize := 10 * time.Second validateCount(s.Scope("Global"), window.NewFixedWindows(windowSize), col, []beam.WindowIntoOption{