Repository: sqoop Updated Branches: refs/heads/sqoop2 2099cbad6 -> 162615742
SQOOP-1837: Sqoop2: Verify that executing job has been successful in ConnectorTestCase (Jarek Jarcec Cecho via Abraham Elmahrek) Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/16261574 Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/16261574 Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/16261574 Branch: refs/heads/sqoop2 Commit: 1626157427cbbfd8b76e5641ff4e0b41de653dd1 Parents: 2099cba Author: Abraham Elmahrek <[email protected]> Authored: Mon Dec 8 10:40:56 2014 -0600 Committer: Abraham Elmahrek <[email protected]> Committed: Mon Dec 8 10:40:56 2014 -0600 ---------------------------------------------------------------------- .../apache/sqoop/test/testcases/ConnectorTestCase.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/16261574/test/src/main/java/org/apache/sqoop/test/testcases/ConnectorTestCase.java ---------------------------------------------------------------------- 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 3da0693..4f5f52a 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.MJob; 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 @@ abstract public class ConnectorTestCase extends TomcatTestCase { * @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()); } /**
