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 <[email protected]> Authored: Thu May 24 09:09:36 2018 -0500 Committer: Jason Lowe <[email protected]> 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(
