github/sqoop
5
0
Fork 0
mirror of https://github.com/apache/sqoop.git synced 2025-05-11 22:41:50 +08:00
Code Issues Projects Releases Wiki Activity

SQOOP-1837: Sqoop2: Verify that executing job has been successful in ConnectorTestCase

Browse Source 
(Jarek Jarcec Cecho via Abraham Elmahrek)
This commit is contained in:
Abraham Elmahrek 2014-12-08 10:40:56 -06:00
parent 2099cbad65
commit 1626157427
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
test/src/main/java/org/apache/sqoop/test/testcases/ConnectorTestCase.java
View File

@ -34,6 +34,7 @@
import org.apache.sqoop.model.MLink; import org.apache.sqoop.model.MLink;
import org.apache.sqoop.model.MPersistableEntity; import org.apache.sqoop.model.MPersistableEntity;
import org.apache.sqoop.model.MSubmission; 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.Cities;
import org.apache.sqoop.test.data.UbuntuReleases; import org.apache.sqoop.test.data.UbuntuReleases;
import org.apache.sqoop.test.hadoop.HadoopMiniClusterRunner; import org.apache.sqoop.test.hadoop.HadoopMiniClusterRunner;
@ -242,7 +243,14 @@ protected void saveJob(MJob job) {
* @throws Exception * @throws Exception
*/ */
protected void executeJob(long jid) 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());
} }
/** /**