From dbb2996316b914c6a299f5c3b523afed92afd3f4 Mon Sep 17 00:00:00 2001 From: Eugene Kirpichov Date: Fri, 16 Jun 2017 14:27:51 -0700 Subject: [PATCH] Increases backoff in GcsUtil --- .../src/main/java/org/apache/beam/sdk/util/GcsUtil.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/util/GcsUtil.java b/sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/util/GcsUtil.java index 8d1fe74ad270..d7205bf75631 100644 --- a/sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/util/GcsUtil.java +++ b/sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/util/GcsUtil.java @@ -135,7 +135,7 @@ public static GcsUtil create( private static final int MAX_CONCURRENT_BATCHES = 256; private static final FluentBackoff BACKOFF_FACTORY = - FluentBackoff.DEFAULT.withMaxRetries(3).withInitialBackoff(Duration.millis(200)); + FluentBackoff.DEFAULT.withMaxRetries(10).withInitialBackoff(Duration.standardSeconds(1)); /////////////////////////////////////////////////////////////////////////////