From 1626157427cbbfd8b76e5641ff4e0b41de653dd1 Mon Sep 17 00:00:00 2001 From: Abraham Elmahrek Date: Mon, 8 Dec 2014 10:40:56 -0600 Subject: [PATCH] SQOOP-1837: Sqoop2: Verify that executing job has been successful in ConnectorTestCase (Jarek Jarcec Cecho via Abraham Elmahrek) --- .../apache/sqoop/test/testcases/ConnectorTestCase.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/test/src/main/java/org/apache/sqoop/test/testcases/ConnectorTestCase.java b/test/src/main/java/org/apache/sqoop/test/testcases/ConnectorTestCase.java index 3da0693c..4f5f52a3 100644 --- a/test/src/main/java/org/apache/sqoop/test/testcases/ConnectorTestCase.java +++ b/test/src/main/java/org/apache/sqoop/test/testcases/ConnectorTestCase.java @@ -34,6 +34,7 @@ import org.apache.sqoop.model.MLink; import org.apache.sqoop.model.MPersistableEntity; import org.apache.sqoop.model.MSubmission; +import org.apache.sqoop.submission.SubmissionStatus; import org.apache.sqoop.test.data.Cities; import org.apache.sqoop.test.data.UbuntuReleases; import org.apache.sqoop.test.hadoop.HadoopMiniClusterRunner; @@ -242,7 +243,14 @@ protected void saveJob(MJob job) { * @throws Exception */ protected void executeJob(long jid) throws Exception { - getClient().startJob(jid, DEFAULT_SUBMISSION_CALLBACKS, 100); + MSubmission finalSubmission = getClient().startJob(jid, DEFAULT_SUBMISSION_CALLBACKS, 100); + + if(finalSubmission.getStatus().isFailure()) { + LOG.error("Submission has failed: " + finalSubmission.getExceptionInfo()); + LOG.error("Corresponding stack trace: " + finalSubmission.getExceptionStackTrace()); + } + + assertEquals("Submission has failed with " + finalSubmission.getExceptionInfo(), SubmissionStatus.SUCCEEDED, finalSubmission.getStatus()); } /**