You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by da...@apache.org on 2015/05/24 22:52:00 UTC
svn commit: r1681528 - /pig/trunk/test/org/apache/pig/test/TestAssert.java
Author: daijy
Date: Sun May 24 20:52:00 2015
New Revision: 1681528
URL: http://svn.apache.org/r1681528
Log:
PIG-3994: Implement getting backend exception for Tez (PIG-3994-2.patch)
Modified:
pig/trunk/test/org/apache/pig/test/TestAssert.java
Modified: pig/trunk/test/org/apache/pig/test/TestAssert.java
URL: http://svn.apache.org/viewvc/pig/trunk/test/org/apache/pig/test/TestAssert.java?rev=1681528&r1=1681527&r2=1681528&view=diff
==============================================================================
--- pig/trunk/test/org/apache/pig/test/TestAssert.java (original)
+++ pig/trunk/test/org/apache/pig/test/TestAssert.java Sun May 24 20:52:00 2015
@@ -116,8 +116,13 @@ public class TestAssert {
try {
pigServer.openIterator("A");
} catch (FrontendException fe) {
- Assert.assertTrue(fe.getCause().getMessage().contains(
- "Job terminated with anomalous status FAILED"));
+ if (pigServer.getPigContext().getExecType().toString().startsWith("TEZ")) {
+ Assert.assertTrue(fe.getCause().getMessage().contains(
+ "Assertion violated: i should be greater than 1"));
+ } else {
+ Assert.assertTrue(fe.getCause().getMessage().contains(
+ "Job terminated with anomalous status FAILED"));
+ }
}
}
@@ -142,8 +147,13 @@ public class TestAssert {
try {
pigServer.openIterator("A");
} catch (FrontendException fe) {
- Assert.assertTrue(fe.getCause().getMessage().contains(
- "Job terminated with anomalous status FAILED"));
+ if (pigServer.getPigContext().getExecType().toString().startsWith("TEZ")) {
+ Assert.assertTrue(fe.getCause().getMessage().contains(
+ "Assertion violated: i should be greater than 1"));
+ } else {
+ Assert.assertTrue(fe.getCause().getMessage().contains(
+ "Job terminated with anomalous status FAILED"));
+ }
}
}