kaiwangleo commented on issue #16646: URL: https://github.com/apache/iceberg/issues/16646#issuecomment-5611338923
Thanks for opening this issue. I implemented `ALTER TABLE ... DROP PARTITION` support in the Iceberg Flink catalog. The implementation: - translates `CatalogPartitionSpec` using partition field names into an Iceberg row filter; - supports identity partition fields and rejects unsupported transforms with a clear catalog error; - handles typed partition values, including integer, date, timestamp/time, binary/fixed, and null values; - checks partition existence before deleting, so `DROP IF EXISTS` does not create an unnecessary snapshot; - aligns `listPartitions` values with the format accepted by `DROP PARTITION`; - is implemented consistently for Flink 1.20, 2.1, 2.2, and 2.3. Tests cover SQL execution, multiple fields, typed and null values, missing partitions/tables, unpartitioned tables, unsupported transforms, and the no-op `DROP IF EXISTS` path. Validation completed: - all four Flink version test tasks passed; - Gradle reported `BUILD SUCCESSFUL` with 68 actionable tasks; - `git diff --check` passed. The local Spotless check could not be started because the Windows checkout's CRLF-formatted Gradle wrapper cannot be executed from the WSL mount; this is an environment limitation rather than a test or compilation failure. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
