[
https://issues.apache.org/jira/browse/FLINK-41363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18138788#comment-18138788
]
Muhammad commented on FLINK-41363:
----------------------------------
I have a POC for the above with me and happy to contribute.
> Make ALTER TABLE ADD statements idempotent
> ------------------------------------------
>
> Key: FLINK-41363
> URL: https://issues.apache.org/jira/browse/FLINK-41363
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / API
> Reporter: Muhammad
> Priority: Major
>
> The addition of `ALTER TABLE <table> ADD COLUMN` to a Flink job makes the job
> kind of non-idempotent. This means the job will run fine for the first time
> but later it'll fail until the ALTER TABLE command is removed.
> A broader idea is to support something like ALTER TABLE <table> ADD [COLUMN]
> IF NOT EXISTS pattern. This pattern is pretty common with many datastores
> like Postgres, Cassandra, Clickhouse etc. This can be extended to other types
> like PARTITIONS, CONSTRAINTS etc as well.
--
This message was sent by Atlassian Jira
(v10.3.26#10030026)
