Docs: Flink can add/drop/modify columns #13617
Merged
Conversation
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Per https://issues.apache.org/jira/browse/FLINK-21634, these features are now available. e.g. ```sql Flink SQL> SET 'execution.checkpointing.interval' = '30s'; [INFO] Execute statement succeeded. Flink SQL> CREATE TABLE test01 (col1 INT) > WITH ( > 'connector' = 'iceberg', > 'catalog-name' = 'foo', > 'catalog-database' = 'my_glue_db', > 'warehouse' = 's3://rmoff-lakehouse/00/', > 'catalog-impl' = 'org.apache.iceberg.aws.glue.GlueCatalog', > 'ioImpl' = 'org.apache.iceberg.aws.s3.S3FileIO'); [INFO] Execute statement succeeded. -- Add a column Flink SQL> ALTER TABLE test01 ADD test_col INT; [INFO] Execute statement succeeded. Flink SQL> DESCRIBE test01; +----------+------+------+-----+--------+-----------+ | name | type | null | key | extras | watermark | +----------+------+------+-----+--------+-----------+ | col1 | INT | TRUE | | | | | test_col | INT | TRUE | | | | +----------+------+------+-----+--------+-----------+ 2 rows in set -- Drop a column Flink SQL> ALTER TABLE test01 DROP test_col; [INFO] Execute statement succeeded. Flink SQL> DESCRIBE test01; +------+------+------+-----+--------+-----------+ | name | type | null | key | extras | watermark | +------+------+------+-----+--------+-----------+ | col1 | INT | TRUE | | | | +------+------+------+-----+--------+-----------+ 1 row in set -- Rename a column Flink SQL> ALTER TABLE test01 RENAME test_col TO foo; [INFO] Execute statement succeeded. Flink SQL> DESCRIBE test01; +------+------+------+-----+--------+-----------+ | name | type | null | key | extras | watermark | +------+------+------+-----+--------+-----------+ | col1 | INT | TRUE | | | | | foo | INT | TRUE | | | | +------+------+------+-----+--------+-----------+ 2 rows in set -- Modify a column Flink SQL> ALTER TABLE test01 MODIFY col1 STRING; [INFO] Execute statement succeeded. ```
rmoff
changed the title
mxm
approved these changes
Jul 22, 2025
docs/docs/flink.md
Outdated
|
|
||
| * Don't support creating iceberg table with hidden partitioning. [Discussion](http://mail-archives.apache.org/mod_mbox/flink-dev/202008.mbox/%3cCABi+2jQCo3MsOa4+ywaxV5J-Z8TGKNZDX-pQLYB-dG+dVUMiMw@mail.gmail.com%3e) in flink mail list. | ||
| * Don't support creating iceberg table with computed column. | ||
| * Don't support creating iceberg table with watermark. |
Contributor
There was a problem hiding this comment.
Side note: This is also not true anymore: #12191
Contributor
Author
There was a problem hiding this comment.
shall we remove that in this PR too? or open a new one?
Contributor
There was a problem hiding this comment.
While we're on it, we can simply remove this one as well. What do you think?
Contributor
Author
There was a problem hiding this comment.
yes, makes sense. So the two remaining features to list as not implemented are:
- Don't support creating iceberg table with hidden partitioning. Discussion in flink mail list.
- Don't support creating iceberg table with computed column.
is that right?
Contributor
There was a problem hiding this comment.
Yes @rmoff, those are the 2 last missing features mentioned here.
Could you please update the doc accordingly?
Thanks,
Peter
Contributor
Author
There was a problem hiding this comment.
@pvary could you review/merge please? thanks.
pvary
approved these changes
Aug 6, 2025
Contributor
Fokko
changed the title
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
3 participants
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Per https://issues.apache.org/jira/browse/FLINK-21634, these features are now available.
e.g.