(datafusion-ballista) branch main updated: fix: serialize optimized logical plan to fix subquery support (#1586)

[ag...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

andygrove pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion-ballista.git


The following commit(s) were added to refs/heads/main by this push:
     new 48afb8f5e fix: serialize optimized logical plan to fix subquery support (#1586)
48afb8f5e is described below

commit 48afb8f5ef7db57e9df4ad1e86dc3d6419a4280a
Author: Andy Grove <ag...@apache.org>
AuthorDate: Sun Apr 26 16:40:58 2026 -0600

    fix: serialize optimized logical plan to fix subquery support (#1586)
---
 python/python/ballista/extension.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/python/python/ballista/extension.py b/python/python/ballista/extension.py
index 87f2d6d66..a31767fbb 100644
--- a/python/python/ballista/extension.py
+++ b/python/python/ballista/extension.py
@@ -121,7 +121,7 @@ class DistributedDataFrame(DataFrame, metaclass=type):
     # session context, and ballista planner.
     #
     def _to_internal_df(self):
-        blob_plan = self.logical_plan().to_proto()
+        blob_plan = self.optimized_logical_plan().to_proto()
         df = create_ballista_data_frame(blob_plan, self.address, self._session_id)
         return df
 


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@datafusion.apache.org
For additional commands, e-mail: commits-help@datafusion.apache.org