-
Notifications
You must be signed in to change notification settings - Fork 2.4k
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
Data, Flink, Spark: Test deletes with format-version=3 #11538
Conversation
@@ -441,12 +441,6 @@ public void testPartitionSpecEvolutionRemovalV2() { | |||
assertThat(tasks).hasSize(expectedScanTaskCount(3)); | |||
} | |||
|
|||
private DeleteFile posDelete(Table table, DataFile dataFile) { |
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.
this addresses #11485 (comment)
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.
Minor naming comment + some questions on some cases where we're only testing v2, but I think we may as well start testing v3?
spark/v3.3/spark/src/test/java/org/apache/iceberg/spark/source/TestSparkReaderDeletes.java
Outdated
Show resolved
Hide resolved
mr/src/test/java/org/apache/iceberg/mr/TestInputFormatReaderDeletes.java
Show resolved
Hide resolved
data/src/test/java/org/apache/iceberg/data/DeleteReadTests.java
Outdated
Show resolved
Hide resolved
86955f4
to
b8534f2
Compare
b8534f2
to
bbd0810
Compare
bbd0810
to
bccbc14
Compare
this is part of #11122