Skip to content

Commit

Permalink
Fix AzFileSystem retry policy
Browse files Browse the repository at this point in the history
Signed-off-by: Paolo Di Tommaso <[email protected]>
  • Loading branch information
pditommaso committed Jun 17, 2023
1 parent de58697 commit ba9b6d1
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -543,8 +543,7 @@ class AzFileSystem extends FileSystem {
* @return The result of the supplied action
*/
protected <T> T apply(CheckedSupplier<T> action) {
final cond = (e -> e instanceof IOException) as Predicate<? extends Throwable>
final policy = retryPolicy(cond)
final policy = retryPolicy((Throwable t) -> t instanceof IOException || t.cause instanceof IOException)
return Failsafe.with(policy).get(action)
}
}

0 comments on commit ba9b6d1

Please sign in to comment.