fix(risingwave): set implicit flush to true (#8929)

ibis-project · Apr 12, 2024 · fe16877 · fe16877
1 parent ca97867
commit fe16877
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/ibis/backends/risingwave/__init__.py b/ibis/backends/risingwave/__init__.py
@@ -119,6 +119,7 @@ def do_connect(
 
         with self.begin() as cur:
             cur.execute("SET TIMEZONE = UTC")
+            cur.execute("SET RW_IMPLICIT_FLUSH TO true;")
 
     def create_table(
         self,