fix(flink): fix the pandas conversion in execute

ibis-project · Aug 23, 2023 · 2f6564f · 2f6564f
1 parent 5dcc0db
commit 2f6564f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ibis/backends/flink/__init__.py b/ibis/backends/flink/__init__.py
@@ -139,7 +139,7 @@ def execute(self, expr: ir.Expr, **kwargs: Any) -> Any:
         table_expr = expr.as_table()
         sql = self.compile(table_expr, **kwargs)
         df = self._table_env.sql_query(sql).to_pandas()
-        return table_expr.__pandas_result__(df)
+        return expr.__pandas_result__(df)
 
     def create_table(
         self,