chenjunjiedada commented on PR #7171:
URL: https://github.com/apache/iceberg/pull/7171#issuecomment-1548779483
> I am wondering if we should just pass the same read-only
SerializableTable to IcebergFilesCommitter so that it also use the same table
spec as the IcebergStreamingWriter/RowDataTaskWriterFactory.
@stevenzwu, We also have a requirement to migrate the table without
restarting the Flink job since users may have thousands of production streaming
jobs online. Right now, I don't have a full solution in my mind, the early
thinking is to notify the task manager to update the writer after checkpoint.
Do you have a such kind requirement as well? Any idea？
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
