[trinodb#5] fail fast when iceberg ranger error occurs

rice668 · Mar 9, 2022 · bfb19ea · bfb19ea
1 parent cf039a4
commit bfb19ea
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...eberg/src/main/java/io/trino/plugin/iceberg/catalog/AbstractMetastoreTableOperations.java b/...eberg/src/main/java/io/trino/plugin/iceberg/catalog/AbstractMetastoreTableOperations.java
@@ -292,6 +292,8 @@ protected void refreshFromMetadataLocation(String newLocation)
         Tasks.foreach(newLocation)
                 .retry(20)
                 .exponentialBackoff(100, 5000, 600000, 4.0)
+                .throwFailureWhenFinished()
+                .shouldRetryTest(e -> e.getCause() == null || !e.getCause().toString().contains("Permission denied"))
                 .run(metadataLocation -> newMetadata.set(
                         TableMetadataParser.read(this, io().newInputFile(metadataLocation))));