From 2f6564f0ab8b0faf64f801eabaf73f34ba5ddaf0 Mon Sep 17 00:00:00 2001
From: Deepyaman Datta <deepyaman.datta@utexas.edu>
Date: Wed, 23 Aug 2023 14:32:12 -0600
Subject: [PATCH] fix(flink): fix the pandas conversion in `execute`

---
 ibis/backends/flink/__init__.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/ibis/backends/flink/__init__.py b/ibis/backends/flink/__init__.py
index 82ebbca6ac1b..3dbfa88d42a7 100644
--- 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,