replay: explcitly flush when replaying flushes

To more closely model the captured workload, explicitly flush the memtable after committing a flush batch.
jbowens · Feb 3, 2023 · 115cde7 · 115cde7
1 parent 47a88dd
commit 115cde7
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 {