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);