tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bi...@apache.org
Subject tez git commit: TEZ-2774. fix findbugs addendum to add a preemption periodic log
Date Fri, 18 Sep 2015 01:16:12 GMT
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 <bikas@apache.org>
Authored: Thu Sep 17 18:16:02 2015 -0700
Committer: Bikas Saha <bikas@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();
   }


Mime
View raw message