chore(flink): provide flink memtable creator with schema

ibis-project · Sep 23, 2024 · 5ee91ef · 5ee91ef
1 parent 0321fb0
commit 5ee91ef
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ibis/backends/flink/__init__.py b/ibis/backends/flink/__init__.py
@@ -375,7 +375,7 @@ def _register_in_memory_table(self, op: ops.InMemoryTable) -> None:
                 f"{self.name} cannot yet reliably handle `null` typed columns; "
                 f"got null typed columns: {null_columns}"
             )
-        self.create_view(op.name, op.data.to_frame(), temp=True)
+        self.create_view(op.name, op.data.to_frame(), schema=op.schema, temp=True)
 
     def _finalize_memtable(self, name: str) -> None:
         self.drop_view(name, temp=True, force=True)