diff --git a/tests-integration/src/tests/instance_kafka_wal_test.rs b/tests-integration/src/tests/instance_kafka_wal_test.rs
index 1aba70e6465c..7e2ec36fb2ac 100644
--- a/tests-integration/src/tests/instance_kafka_wal_test.rs
+++ b/tests-integration/src/tests/instance_kafka_wal_test.rs
@@ -119,7 +119,7 @@ async fn test_flush_then_replay(rebuildable_instance: Option<Box<dyn Rebuildable
     insert_data(&tables, &instance, 5).await;
     ensure_data_exists(&tables, &instance).await;
 
-    // Renames tables to force flusing each table.
+    // Renames tables to force flushing each table.
     let tables = futures::future::join_all(tables.into_iter().map(|table| {
         let instance = instance.clone();
         async move {