replay: explcitly flush when replaying flushes

To more closely model the captured workload, explicitly flush the memtable after committing a flush batch.
cockroachdb · Feb 6, 2023 · 4eba71e · 4eba71e
1 parent e935ca0
commit 4eba71e
Showing 1 changed file with 4 additions and 0 deletions.
diff --git 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 {