You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sqoop.apache.org by ab...@apache.org on 2014/12/08 18:14:24 UTC
sqoop git commit: SQOOP-1837: Sqoop2: Verify that executing job has
been successful in ConnectorTestCase
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 <ab...@apache.org>
Authored: Mon Dec 8 10:40:56 2014 -0600
Committer: Abraham Elmahrek <ab...@apache.org>
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());
}
/**