You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by ab...@apache.org on 2021/02/08 19:27:26 UTC
[tez] branch master updated: TEZ-4273: Clear off staging files when TezYarnClient is unable to submit applications (Rajesh Balamohan via László Bodor) - addendum test fix
This is an automated email from the ASF dual-hosted git repository.
abstractdog pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/tez.git
The following commit(s) were added to refs/heads/master by this push:
new cd05486 TEZ-4273: Clear off staging files when TezYarnClient is unable to submit applications (Rajesh Balamohan via László Bodor) - addendum test fix
cd05486 is described below
commit cd0548631dd10be5f0d6c13d295f2726d180d239
Author: Laszlo Bodor <bo...@gmail.com>
AuthorDate: Mon Feb 8 20:21:39 2021 +0100
TEZ-4273: Clear off staging files when TezYarnClient is unable to submit applications (Rajesh Balamohan via László Bodor) - addendum test fix
---
.../src/test/java/org/apache/tez/dag/app/TestMockDAGAppMaster.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/tez-dag/src/test/java/org/apache/tez/dag/app/TestMockDAGAppMaster.java b/tez-dag/src/test/java/org/apache/tez/dag/app/TestMockDAGAppMaster.java
index 1a46595..5dca694 100644
--- a/tez-dag/src/test/java/org/apache/tez/dag/app/TestMockDAGAppMaster.java
+++ b/tez-dag/src/test/java/org/apache/tez/dag/app/TestMockDAGAppMaster.java
@@ -958,7 +958,7 @@ public class TestMockDAGAppMaster {
tezClient.start();
} catch (Exception e) {
e.printStackTrace();
- Assert.assertEquals("FailInit", e.getCause().getCause().getMessage());
+ Assert.assertEquals("FailInit", e.getCause().getCause().getCause().getMessage());
MockDAGAppMaster mockApp = tezClient.getLocalClient().getMockApp();
// will timeout if DAGAppMasterShutdownHook is not invoked
mockApp.waitForServiceToStop(Integer.MAX_VALUE);
@@ -974,7 +974,7 @@ public class TestMockDAGAppMaster {
tezClient.start();
} catch (Exception e) {
e.printStackTrace();
- Assert.assertEquals("FailStart", e.getCause().getCause().getMessage());
+ Assert.assertEquals("FailStart", e.getCause().getCause().getCause().getMessage());
MockDAGAppMaster mockApp = tezClient.getLocalClient().getMockApp();
// will timeout if DAGAppMasterShutdownHook is not invoked
mockApp.waitForServiceToStop(Integer.MAX_VALUE);