We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
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
append() is deleting records
Any idea why?
Delta-rs version: 0.18.2
Binding:
Environment:
3.10.12
What happened:
The following write_deltalake function is deleting records and not only appending
import pyarrow as pa pa_table = pa.Table.from_pandas(validated_df, schema=merged_schema, preserve_index=False) write_deltalake( abfss_table_path, pa_table, mode="append", schema_mode="merge", engine="rust", storage_options=storage_options, )
What you expected to happen:
I'd expect row count to increase, however row count decreased significantly!
How to reproduce it:
This is a very large table with 300k+ records
Resulting delta table became 30k+ records, deleting hundreds of thousands
More details:
The text was updated successfully, but these errors were encountered:
@machov I can look into it if you give a reproducible example
Sorry, something went wrong.
good point, let me look into that, closing for now,
No branches or pull requests
Environment
append() is deleting records
Any idea why?
Delta-rs version: 0.18.2
Binding:
Environment:
3.10.12
Bug
What happened:
The following write_deltalake function is deleting records and not only appending
What you expected to happen:
I'd expect row count to increase, however row count decreased significantly!
How to reproduce it:
This is a very large table with 300k+ records
Resulting delta table became 30k+ records, deleting hundreds of thousands
More details:
The text was updated successfully, but these errors were encountered: