diff --git a/replay/replay.go b/replay/replay.go
index 8c40662a3d..c40241a1ad 100644
--- a/replay/replay.go
+++ b/replay/replay.go
@@ -537,6 +537,10 @@ func (r *Runner) applyWorkloadSteps(ctx context.Context) error {
 			if err := step.flushBatch.Commit(&pebble.WriteOptions{Sync: false}); err != nil {
 				return err
 			}
+			_, err := r.d.AsyncFlush()
+			if err != nil {
+				return err
+			}
 			r.stepsApplied <- step
 		case ingestStepKind:
 			if err := r.d.Ingest(step.tablesToIngest); err != nil {