tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jl...@apache.org
Subject tez git commit: TEZ-3939. Remove performance hit of precondition check in AM for register running task attempt (Jonathan Eagles via jlowe)
Date Thu, 24 May 2018 14:13:24 GMT
Repository: tez
Updated Branches:
  refs/heads/branch-0.9 fa5c9f3a4 -> 364ae4faf


TEZ-3939. Remove performance hit of precondition check in AM for register running task attempt
(Jonathan Eagles via jlowe)

(cherry picked from commit f6624c1525c54f64bdf28996fc469fa5543df6af)


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

Branch: refs/heads/branch-0.9
Commit: 364ae4fafb2faef3ddc85e5820a80cd367850792
Parents: fa5c9f3
Author: Jason Lowe <jlowe@apache.org>
Authored: Thu May 24 09:09:36 2018 -0500
Committer: Jason Lowe <jlowe@apache.org>
Committed: Thu May 24 09:11:55 2018 -0500

----------------------------------------------------------------------
 .../java/org/apache/tez/dag/app/TezTaskCommunicatorImpl.java    | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/tez/blob/364ae4fa/tez-dag/src/main/java/org/apache/tez/dag/app/TezTaskCommunicatorImpl.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/TezTaskCommunicatorImpl.java b/tez-dag/src/main/java/org/apache/tez/dag/app/TezTaskCommunicatorImpl.java
index 9b700f8..d52df4f 100644
--- a/tez-dag/src/main/java/org/apache/tez/dag/app/TezTaskCommunicatorImpl.java
+++ b/tez-dag/src/main/java/org/apache/tez/dag/app/TezTaskCommunicatorImpl.java
@@ -221,9 +221,8 @@ public class TezTaskCommunicatorImpl extends TaskCommunicator {
                                          int priority) {
 
     ContainerInfo containerInfo = registeredContainers.get(containerId);
-    Preconditions.checkNotNull(containerInfo,
-        "Cannot register task attempt: " + taskSpec.getTaskAttemptID() + " to unknown container:
" +
-            containerId);
+    Preconditions.checkNotNull(containerInfo, "Cannot register task attempt %s to unknown
container %s",
+        taskSpec.getTaskAttemptID(), containerId);
     synchronized (containerInfo) {
       if (containerInfo.taskSpec != null) {
         throw new TezUncheckedException(


Mime
View raw message