You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@iceberg.apache.org by "leichangqing (via GitHub)" <gi...@apache.org> on 2023/03/10 01:17:08 UTC

[GitHub] [iceberg] leichangqing commented on issue #4190: flink:FlinkSink support dynamically changed schema

leichangqing commented on issue #4190:
URL: https://github.com/apache/iceberg/issues/4190#issuecomment-1463065147

   > We also met this problem in our scenarios. We modify schema of the sink iceberg table frequently. Now I try to get the table schema through iceberg table refresh api to dynamically construct a DataStream to add new columns. It is possible to add new columns, but writing new columns to iceberg sink does not take effect, because sink does not support dynamic update of schema.If iceberg flink sink writer can add iceberg table refresh function support, it will be more convenient to use. After all, it takes a minute or two to restart flink now. @stevenzwu
   
   I have interesting on this, how to contact with u about dynamical schema


-- 
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: issues-unsubscribe@iceberg.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@iceberg.apache.org
For additional commands, e-mail: issues-help@iceberg.apache.org