Re: [I] flink:FlinkSink support dynamically changed schema [iceberg]

2024-04-17 Thread via GitHub
pvary commented on issue #4190: URL: https://github.com/apache/iceberg/issues/4190#issuecomment-2061836288 I think it is not trivial to implement this feature, as the schema of the RowData objects which are the input of the Sink is finalized when the job graph is created. To change the

Re: [I] flink:FlinkSink support dynamically changed schema [iceberg]

2024-04-16 Thread via GitHub
Ruees commented on issue #4190: URL: https://github.com/apache/iceberg/issues/4190#issuecomment-2058647346 > @leichangqing You can refer to the last two commits of my branch https://github.com/lintingbin2009/iceberg/tree/flink-sink-dynamically-change. We have put this part of the code in

Re: [I] flink:FlinkSink support dynamically changed schema [iceberg]

2024-04-15 Thread via GitHub
Ruees commented on issue #4190: URL: https://github.com/apache/iceberg/issues/4190#issuecomment-2058150468 > @leichangqing You can refer to the last two commits of my branch https://github.com/lintingbin2009/iceberg/tree/flink-sink-dynamically-change. We have put this part of the code in

Re: [I] flink:FlinkSink support dynamically changed schema [iceberg]

2024-02-28 Thread via GitHub
FranMorilloAWS commented on issue #4190: URL: https://github.com/apache/iceberg/issues/4190#issuecomment-1969361137 Is there any news on this? -- 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