Apache Iceberg version
1.11.0 (latest release)
Query engine
Flink
Please describe the bug 🐞
Problem
Currently if you try to add column to position through Flink engine, column will be added at the end of the table. The Spark engine works correctly for such operation. So we need a fix for Flink.
Fix
Add applyModifyColumnPosition if addColumn.getPosition() != null
Verification
- Added
testAlterTableAddColumnPosition() to TestFlinkCatalogTable
Willingness to contribute
Apache Iceberg version
1.11.0 (latest release)
Query engine
Flink
Please describe the bug 🐞
Problem
Currently if you try to add column to position through Flink engine, column will be added at the end of the table. The Spark engine works correctly for such operation. So we need a fix for Flink.
Fix
Add
applyModifyColumnPositionifaddColumn.getPosition() != nullVerification
testAlterTableAddColumnPosition()toTestFlinkCatalogTableWillingness to contribute