You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by bi...@apache.org on 2015/09/18 03:16:12 UTC
tez git commit: TEZ-2774. fix findbugs addendum to add a preemption
periodic log
Repository: tez
Updated Branches:
refs/heads/master 1a065b9d8 -> 35cf02382
TEZ-2774. fix findbugs addendum to add a preemption periodic log
Project: http://git-wip-us.apache.org/repos/asf/tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/35cf0238
Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/35cf0238
Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/35cf0238
Branch: refs/heads/master
Commit: 35cf0238282dca9229c7184e810df467dcda800c
Parents: 1a065b9
Author: Bikas Saha <bi...@apache.org>
Authored: Thu Sep 17 18:16:02 2015 -0700
Committer: Bikas Saha <bi...@apache.org>
Committed: Thu Sep 17 18:16:02 2015 -0700
----------------------------------------------------------------------
.../org/apache/tez/dag/app/rm/YarnTaskSchedulerService.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/tez/blob/35cf0238/tez-dag/src/main/java/org/apache/tez/dag/app/rm/YarnTaskSchedulerService.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/rm/YarnTaskSchedulerService.java b/tez-dag/src/main/java/org/apache/tez/dag/app/rm/YarnTaskSchedulerService.java
index 9aa2ef3..3c1cf3f 100644
--- a/tez-dag/src/main/java/org/apache/tez/dag/app/rm/YarnTaskSchedulerService.java
+++ b/tez-dag/src/main/java/org/apache/tez/dag/app/rm/YarnTaskSchedulerService.java
@@ -890,8 +890,10 @@ public class YarnTaskSchedulerService extends TaskScheduler
" taskAllocations: " + taskAllocations.size());
}
- numHeartbeats++;
- preemptIfNeeded();
+ synchronized (this) {
+ numHeartbeats++;
+ preemptIfNeeded();
+ }
return getContext().getProgress();
}