diff --git a/go/vt/vttablet/tabletmanager/vreplication/vplayer_parallel_worker.go b/go/vt/vttablet/tabletmanager/vreplication/vplayer_parallel_worker.go
index 67f9e1b722b..fe3ae331358 100644
--- a/go/vt/vttablet/tabletmanager/vreplication/vplayer_parallel_worker.go
+++ b/go/vt/vttablet/tabletmanager/vreplication/vplayer_parallel_worker.go
@@ -154,6 +154,9 @@ func (w *parallelWorker) applyQueuedEvents(ctx context.Context) (err error) {
 		}
 	}()
 	for {
+		if w.pool.posReached.Load() {
+			return io.EOF
+		}
 		select {
 		case <-ctx.Done():
 			return ctx.Err()