You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@giraph.apache.org by di...@apache.org on 2019/05/14 00:32:35 UTC
[giraph] branch trunk updated: GIRAPH-1219
This is an automated email from the ASF dual-hosted git repository.
dionysios pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/giraph.git
The following commit(s) were added to refs/heads/trunk by this push:
new 12b2d74 GIRAPH-1219
12b2d74 is described below
commit 12b2d7430f51b3e0195e5a7320d27429c1b39edf
Author: Dionysios Logothetis <dl...@gmail.com>
AuthorDate: Mon May 13 17:32:13 2019 -0700
GIRAPH-1219
closes #102
---
.../giraph/graph/RetryableJobProgressTrackerClient.java | 14 +++++++++++---
1 file changed, 11 insertions(+), 3 deletions(-)
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 369feec..2fa4446 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
@@ -201,14 +201,22 @@ public class RetryableJobProgressTrackerClient
retry(runnable);
break; // If the retry succeeded, we simply break from the loop
- // CHECKSTYLE: stop IllegalCatch
- } catch (Exception e) {
- // CHECKSTYLE: resume IllegalCatch
+ } catch (RuntimeTTransportException | RejectedExecutionException e) {
+ // If a RuntimeTTTransportException happened, then we will retry
if (LOG.isInfoEnabled()) {
LOG.info("Exception occurred while talking to " +
"JobProgressTracker server after retry " + i +
" of " + numRetries, e);
}
+ // CHECKSTYLE: stop IllegalCatch
+ } catch (Exception e) {
+ // CHECKSTYLE: resume IllegalCatch
+ // If any other exception happened (e.g. application-specific),
+ // then we stop.
+ LOG.info("Exception occurred while talking to " +
+ "JobProgressTracker server after retry " + i +
+ " of " + numRetries + ", giving up", e);
+ break;
}
}
// CHECKSTYLE: stop IllegalCatch