You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@giraph.apache.org by ma...@apache.org on 2018/02/12 18:52:47 UTC

git commit: updated refs/heads/trunk to 1484572

Repository: giraph
Updated Branches:
  refs/heads/trunk 1f959d076 -> 14845725e


JIRA-1169

closes #58


Project: http://git-wip-us.apache.org/repos/asf/giraph/repo
Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/14845725
Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/14845725
Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/14845725

Branch: refs/heads/trunk
Commit: 14845725ea57e4ff110bc5fd838aabe6e6d20c25
Parents: 1f959d0
Author: Maja Kabiljo <ma...@fb.com>
Authored: Mon Feb 12 10:52:38 2018 -0800
Committer: Maja Kabiljo <ma...@fb.com>
Committed: Mon Feb 12 10:52:38 2018 -0800

----------------------------------------------------------------------
 .../org/apache/giraph/job/DefaultJobProgressTrackerService.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/giraph/blob/14845725/giraph-core/src/main/java/org/apache/giraph/job/DefaultJobProgressTrackerService.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/job/DefaultJobProgressTrackerService.java b/giraph-core/src/main/java/org/apache/giraph/job/DefaultJobProgressTrackerService.java
index d7d03d2..243ab81 100644
--- a/giraph-core/src/main/java/org/apache/giraph/job/DefaultJobProgressTrackerService.java
+++ b/giraph-core/src/main/java/org/apache/giraph/job/DefaultJobProgressTrackerService.java
@@ -180,7 +180,7 @@ public class DefaultJobProgressTrackerService
    * Called when job got all mappers, used to check MAX_ALLOWED_JOB_TIME_MS
    * and potentially start a thread which will kill the job after this time
    */
-  private void jobGotAllMappers() {
+  protected void jobGotAllMappers() {
     jobObserver.jobGotAllMappers(job);
     final long maxAllowedJobTimeMs =
         GiraphConstants.MAX_ALLOWED_JOB_TIME_MS.get(conf);