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 our own production environment and executed it for half a year, and it seems that there is no problem so far. <img alt="image" width="1125" src="https://user-images.githubusercontent.com/5699014/224219390-eac0d0e2-1578-44d8-a6d5-6ba97362e02e.png";> Corresponding to 1, 2, 3 in the above picture, you need to prepare: > > 1. There needs to be a broadcast node that can subscribe to your schema changes. > 2. The data processing node can generate RowData according to the latest schema processing data. > 3. This is based on the above code modification so that the iceberg writer node can receive the latest schema and apply it. Can there be sample code to demonstrate how to use it? -- 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-unsubscr...@iceberg.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org For additional commands, e-mail: issues-h...@iceberg.apache.org
![https://user-images.githubusercontent.com/5699014/224219390-eac0d0e2-1578-44d8-a6d5-6ba97362e02e.png"](https://user-images.githubusercontent.com/5699014/224219390-eac0d0e2-1578-44d8-a6d5-6ba97362e02e.png"){kind=link}