You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by bl...@apache.org on 2019/02/15 21:24:37 UTC
[incubator-iceberg] branch master updated: Remove unnecessary retry
when reading metadata for existing manifest files (#88)
This is an automated email from the ASF dual-hosted git repository.
blue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-iceberg.git
The following commit(s) were added to refs/heads/master by this push:
new e663871 Remove unnecessary retry when reading metadata for existing manifest files (#88)
e663871 is described below
commit e66387134462f0af8689163830eba4ae289800db
Author: Filip Bocse <fi...@gmail.com>
AuthorDate: Fri Feb 15 23:24:33 2019 +0200
Remove unnecessary retry when reading metadata for existing manifest files (#88)
---
core/src/main/java/com/netflix/iceberg/SnapshotUpdate.java | 5 -----
1 file changed, 5 deletions(-)
diff --git a/core/src/main/java/com/netflix/iceberg/SnapshotUpdate.java b/core/src/main/java/com/netflix/iceberg/SnapshotUpdate.java
index 796df2f..0cc98f9 100644
--- a/core/src/main/java/com/netflix/iceberg/SnapshotUpdate.java
+++ b/core/src/main/java/com/netflix/iceberg/SnapshotUpdate.java
@@ -123,11 +123,6 @@ abstract class SnapshotUpdate implements PendingUpdate<Snapshot> {
Tasks.range(manifestFiles.length)
.stopOnFailure().throwFailureWhenFinished()
- .retry(4).exponentialBackoff(
- base.propertyAsInt(COMMIT_MIN_RETRY_WAIT_MS, COMMIT_MIN_RETRY_WAIT_MS_DEFAULT),
- base.propertyAsInt(COMMIT_MAX_RETRY_WAIT_MS, COMMIT_MAX_RETRY_WAIT_MS_DEFAULT),
- base.propertyAsInt(COMMIT_TOTAL_RETRY_TIME_MS, COMMIT_TOTAL_RETRY_TIME_MS_DEFAULT),
- 2.0 /* exponential */ )
.executeWith(getWorkerPool())
.run(index ->
manifestFiles[index] = manifestsWithMetadata.getUnchecked(manifests.get(index)));