diff --git a/e2e/events/events.go b/e2e/events/events.go
index 2a545676b..28c0614a1 100644
--- a/e2e/events/events.go
+++ b/e2e/events/events.go
@@ -218,7 +218,10 @@ func (tc *EventsTest) TestStartIndex(f *framework.F) {
 			select {
 			case <-ctx.Done():
 				return
-			case event := <-streamCh:
+			case event, ok := <-streamCh:
+				if !ok {
+					return
+				}
 				if event.IsHeartbeat() {
 					continue
 				}