diff --git a/test/integration/util/util.go b/test/integration/util/util.go index 7b34f2dc341..abe42f2e362 100644 --- a/test/integration/util/util.go +++ b/test/integration/util/util.go @@ -424,8 +424,7 @@ func InitTestSchedulerWithOptions( t.Fatalf("Couldn't create scheduler: %v", err) } - stopCh := make(chan struct{}) - eventBroadcaster.StartRecordingToSink(stopCh) + eventBroadcaster.StartRecordingToSink(testCtx.Ctx.Done()) return testCtx }