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 <[email protected]> Authored: Thu Sep 17 18:16:02 2015 -0700 Committer: Bikas Saha <[email protected]> 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(); }
