Merge pull request #109781 from wojtek-t/fix_scheduler_tests

Close events recording sink in integration tests

test/integration/util/util.go

@@ -426,8 +426,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
 }