Repository: tez Updated Branches: refs/heads/master c0faeaed6 -> ddfb26222
TEZ-3743. TestTaskCommunicatorContextImpl throws NullPointerException after TEZ-3334 merge (Jonathan Eagles via kshukla) Project: http://git-wip-us.apache.org/repos/asf/tez/repo Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/ddfb2622 Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/ddfb2622 Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/ddfb2622 Branch: refs/heads/master Commit: ddfb262223b7cb07957e1bd48a99d8a2e765aee7 Parents: c0faeae Author: Kuhu Shukla <[email protected]> Authored: Thu May 25 14:23:53 2017 -0500 Committer: Kuhu Shukla <[email protected]> Committed: Thu May 25 14:24:43 2017 -0500 ---------------------------------------------------------------------- .../org/apache/tez/dag/app/TestTaskCommunicatorContextImpl.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tez/blob/ddfb2622/tez-dag/src/test/java/org/apache/tez/dag/app/TestTaskCommunicatorContextImpl.java ---------------------------------------------------------------------- diff --git a/tez-dag/src/test/java/org/apache/tez/dag/app/TestTaskCommunicatorContextImpl.java b/tez-dag/src/test/java/org/apache/tez/dag/app/TestTaskCommunicatorContextImpl.java index 869bfd5..9f9150f 100644 --- a/tez-dag/src/test/java/org/apache/tez/dag/app/TestTaskCommunicatorContextImpl.java +++ b/tez-dag/src/test/java/org/apache/tez/dag/app/TestTaskCommunicatorContextImpl.java @@ -21,7 +21,9 @@ import static org.mockito.Mockito.mock; import static org.mockito.Mockito.never; import static org.mockito.Mockito.reset; import static org.mockito.Mockito.verify; +import static org.mockito.Mockito.when; +import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.yarn.api.records.Container; import org.apache.hadoop.yarn.api.records.ContainerId; import org.apache.tez.common.ContainerSignatureMatcher; @@ -34,6 +36,7 @@ public class TestTaskCommunicatorContextImpl { @Test(timeout = 5000) public void testIsKnownContainer() { AppContext appContext = mock(AppContext.class); + when(appContext.getAMConf()).thenReturn(new Configuration()); TaskCommunicatorManager tal = mock(TaskCommunicatorManager.class); AMContainerMap amContainerMap = new AMContainerMap(mock(ContainerHeartbeatHandler.class), tal, mock(
