nastra opened a new pull request, #15663: URL: https://github.com/apache/iceberg/pull/15663
When accessing/reading data files, the codebase is using the Table's `FileIO` instance through `table.io()` on Flink's read path. With remote scan planning the `FileIO` instance is configured with a PlanID + custom storage credentials inside `RESTTableScan`, but that instance is never propagated to the place(s) that actually perform the read., thus leading to errors. This PR passes the `FileIO` obtained during remote/distributed scan planning next to the `Table` instance on Flink's read path. This is similar to https://github.com/apache/iceberg/pull/15448, where we applied the same approach on Spark's read path -- 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]
