vmaksimenko commented on issue #9955: URL: https://github.com/apache/iceberg/issues/9955#issuecomment-2125315703
I think the keyword for you is a checkpoint of your Flink application. If you are reading in streaming mode and restarting your application then restart it from the latest checkpoint by configuring https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/deployment/config/#execution-savepoint-path , if you do it in batch and provide "from" and "to" parameters for your job then use it to configure as starting and ending boundaries. How you are going to get these parameters is up to the logic of your application. Apache Iceberg does not provide an application checkpoint store for your queries, it has an API to to start from the first, latest or specific snapshotid. -- 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
