Repository: tez Updated Branches: refs/heads/master 7111078e9 -> f6624c152
TEZ-3939. Remove performance hit of precondition check in AM for register running task attempt (Jonathan Eagles via jlowe) Project: http://git-wip-us.apache.org/repos/asf/tez/repo Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/f6624c15 Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/f6624c15 Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/f6624c15 Branch: refs/heads/master Commit: f6624c1525c54f64bdf28996fc469fa5543df6af Parents: 7111078 Author: Jason Lowe <[email protected]> Authored: Thu May 24 09:09:36 2018 -0500 Committer: Jason Lowe <[email protected]> Committed: Thu May 24 09:09:36 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/f6624c15/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(
