- 
                Notifications
    
You must be signed in to change notification settings  - Fork 342
 
fix(reader): Equality delete files with partial schemas (containing only equality columns) #1782
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
fix(reader): Equality delete files with partial schemas (containing only equality columns) #1782
Conversation
…lity delete files. Added new test.
evolve_schema() call in load_file_for_task() for equality deletes| 
           Seems duplicated with #1778 ?  | 
    
          
 I mistakenly mixed changes from the two PRs, but they are independent (but related) fixes with independent tests.  | 
    
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks @mbutrovich for this fix!
| 
           The ci failure is unrelated, it should be fixed by #1823. I'll merge this for now.  | 
    
What issue does this PR close?
Partially address #1749.
Rationale for this change
Equality delete files with partial schemas (containing only equality columns) were hitting Arrow validation errors: "Column 'id' is declared as non-nullable but contains null values” in Iceberg Java’s TestSparkReaderDeletes suite. The bug occurs because
evolve_schema()adds missing columns with NULL values, which fails when those columns are declared REQUIRED in the table schema.What changes are included in this PR?
Change the
evolve_schema()call to takeequality_idsbecause per the Iceberg spec, evolve schema for equality deletes but only for theequality_idscolumns, not all table columns.Are these changes tested?
test_partial_schema_equality_deletes_evolve_succeeds