check for posReached before applying any event

Signed-off-by: Shlomi Noach <[email protected]>
planetscale · Jan 1, 2025 · e054980 · e054980
1 parent 120ab81
commit e054980
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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()