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,