diff --git a/ibis/backends/risingwave/tests/conftest.py b/ibis/backends/risingwave/tests/conftest.py
index 3d6f1b7853516..09064506f262a 100644
--- a/ibis/backends/risingwave/tests/conftest.py
+++ b/ibis/backends/risingwave/tests/conftest.py
@@ -84,7 +84,10 @@ def connect(*, tmpdir, worker_id, port: int | None = None, **kw):
 
 @pytest.fixture(scope="session")
 def con(tmp_path_factory, data_dir, worker_id):
-    return TestConf.load_data(data_dir, tmp_path_factory, worker_id).connection
+    con = TestConf.load_data(data_dir, tmp_path_factory, worker_id).connection
+    cursor = con.raw_sql("SET RW_IMPLICIT_FLUSH TO true;")
+    cursor.close()
+    return con
 
 
 @pytest.fixture(scope="module")