Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

df.write_xxx no longer working in ballista #894

Closed
yarenty opened this issue Oct 19, 2023 · 1 comment · Fixed by #945
Closed

df.write_xxx no longer working in ballista #894

yarenty opened this issue Oct 19, 2023 · 1 comment · Fixed by #945
Labels
bug Something isn't working

Comments

@yarenty
Copy link

yarenty commented Oct 19, 2023

Describe the bug

Since the update to Datafusion 30 ( rev: 7d774481aedc027b7f68226b2c3a4fc0db959fc2 )
as Dataframe moved to use LogicalPlan::Copy when executing write (csv, parquet,json)
df. write_xxx is no longer working in Ballista.

To Reproduce
One can use any sql and then df.write ie: in examples standalone_sql.rs add write_csv() instead show():

    let df = ctx.sql("select count(1) from test").await?;

    df.write_csv("output.csv", DataFrameWriteOptions::default(), None).await?;

cargo run --example standalone_sql

Output:

Error: DataFusionError(Internal("failed to serialize logical plan: Internal(\"LogicalPlan serde is not yet implemented for Copy\")"))

Expected behavior
File created.

Additional context
See PR: apache/datafusion#7283

Looks like this is todo - there are no serde / proto changes in datafusion.

Question: should I ask about it in datafusion repo ?

@yarenty yarenty added the bug Something isn't working label Oct 19, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
bug Something isn't working
Projects
None yet
Development

Successfully merging a pull request may close this issue.

2 participants