venkata91 opened a new pull request, #10776: URL: https://github.com/apache/iceberg/pull/10776
### Summary Add support for Flink's Speculative Execution in batch execution mode ### Details Backport from 1.19 to 1.18 required some manual conflict resolution only in the tests. They are as follows: 1. Instead of `getRuntimeContext().getTaskInfo().getIndexOfThisSubtask()` and `getRuntimeContext().getTaskInfo().getAttemptNumber()` use `getRuntimeContext().getIndexOfThisSubtask()` and `getRuntimeContext().getAttemptNumber()` 2. Add `dropDatabase()` helper method in `TestBase` which required adding `DEFAULT_CATALOG_NAME` as a constant in `FlinkCatalogFactory`. Backport from 1.18 to 1.17 went through cleanly. ### Testing Added an integration test to verify the expected speculative execution behavior with IcebergSource -- 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
