diff --git a/airbyte-to-flow/src/connector_runner.rs b/airbyte-to-flow/src/connector_runner.rs
index b090378a5e1b..0f8f93a05ea3 100644
--- a/airbyte-to-flow/src/connector_runner.rs
+++ b/airbyte-to-flow/src/connector_runner.rs
@@ -274,6 +274,7 @@ async fn streaming_all(
                 Err(e) => Err::<(), std::io::Error>(e.into())?,
             }
         }
+        writer.flush().await?;
 
         response_finished_sender
             .send(true)