commit | 0f41dbb1b40ecdc2e546d1366b8973e576f59486 | [log] [tgz] |
---|---|---|
author | Dionysios Logothetis <dlogothetis@gmail.com> | Fri May 17 10:30:12 2019 -0700 |
committer | Dionysios Logothetis <dionysios@fb.com> | Fri May 17 10:30:12 2019 -0700 |
tree | 6f7aefc23f440cf25ccf70bb4dcf003506d7e03c | |
parent | 12b2d7430f51b3e0195e5a7320d27429c1b39edf [diff] |
GIRAPH-1219 closes #103
diff --git a/giraph-core/src/main/java/org/apache/giraph/graph/RetryableJobProgressTrackerClient.java b/giraph-core/src/main/java/org/apache/giraph/graph/RetryableJobProgressTrackerClient.java index 2fa4446..93e8a24 100644 --- a/giraph-core/src/main/java/org/apache/giraph/graph/RetryableJobProgressTrackerClient.java +++ b/giraph-core/src/main/java/org/apache/giraph/graph/RetryableJobProgressTrackerClient.java
@@ -195,7 +195,7 @@ LOG.debug(te.getClass() + " occurred while talking to " + "JobProgressTracker server, trying to reconnect", te); } - for (int i = 0; i < numRetries; i++) { + for (int i = 1; i <= numRetries; i++) { try { ThreadUtils.trySleep(retryWaitMsec); retry(runnable);