Repository: sqoop Updated Branches: refs/heads/sqoop2 4a5bd295d -> 7edaa11d2
SQOOP-2405: Sqoop2: Remove active wait in test cases after executeJob() call (Banmeet Singh 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/7edaa11d Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/7edaa11d Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/7edaa11d Branch: refs/heads/sqoop2 Commit: 7edaa11d22bedb5597db7c01ed2ddd2d6532e934 Parents: 4a5bd29 Author: Abraham Elmahrek <[email protected]> Authored: Fri Jun 26 10:45:16 2015 -0700 Committer: Abraham Elmahrek <[email protected]> Committed: Fri Jun 26 10:45:16 2015 -0700 ---------------------------------------------------------------------- .../jdbc/generic/FromRDBMSToHDFSTest.java | 32 -------------------- 1 file changed, 32 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/7edaa11d/test/src/test/java/org/apache/sqoop/integration/connector/jdbc/generic/FromRDBMSToHDFSTest.java ---------------------------------------------------------------------- diff --git a/test/src/test/java/org/apache/sqoop/integration/connector/jdbc/generic/FromRDBMSToHDFSTest.java b/test/src/test/java/org/apache/sqoop/integration/connector/jdbc/generic/FromRDBMSToHDFSTest.java index 1272ed9..dac6db7 100644 --- a/test/src/test/java/org/apache/sqoop/integration/connector/jdbc/generic/FromRDBMSToHDFSTest.java +++ b/test/src/test/java/org/apache/sqoop/integration/connector/jdbc/generic/FromRDBMSToHDFSTest.java @@ -103,14 +103,6 @@ public class FromRDBMSToHDFSTest extends ConnectorTestCase { executeJob(job); - // Wait until the job finish - this active waiting will be removed once - // Sqoop client API will get blocking support. - MSubmission submission; - do { - Thread.sleep(5000); - submission = getClient().getJobStatus(job.getPersistenceId()); - } while(submission.getStatus().isRunning()); - // Assert correct output assertTo( "1,'The Gift of the Magi','ONE DOLLAR AND EIGHTY-SEVEN CENTS. THAT WAS ALL. AND SIXTY CENTS of it was in pennies. Pennies saved one and two at a time by bulldozing the grocer and the vegetable man and the butcher until ones cheeks burned with the silent imputation of parsimony that such close dealing implied. Three times Della counted it. One dollar and eighty-seven cents. And the next day would be Christmas.\\n\\nThere was clearly nothing left to do but flop down on the shabby little couch and howl. So Della did it. Which instigates the moral reflection that life is made up of sobs, sniffles, and smiles, with sniffles predominating.'", @@ -149,14 +141,6 @@ public class FromRDBMSToHDFSTest extends ConnectorTestCase { executeJob(job); - // Wait until the job finish - this active waiting will be removed once - // Sqoop client API will get blocking support. - MSubmission submission; - do { - Thread.sleep(5000); - submission = getClient().getJobStatus(job.getPersistenceId()); - } while(submission.getStatus().isRunning()); - // Assert correct output assertTo( "1,'USA'", @@ -197,14 +181,6 @@ public class FromRDBMSToHDFSTest extends ConnectorTestCase { executeJob(job); - // Wait until the job finish - this active waiting will be removed once - // Sqoop client API will get blocking support. - MSubmission submission; - do { - Thread.sleep(5000); - submission = getClient().getJobStatus(job.getPersistenceId()); - } while(submission.getStatus().isRunning()); - // Assert correct output assertTo( "1", @@ -251,14 +227,6 @@ public class FromRDBMSToHDFSTest extends ConnectorTestCase { executeJob(job); - // Wait until the job finish - this active waiting will be removed once - // Sqoop client API will get blocking support. - MSubmission submission; - do { - Thread.sleep(5000); - submission = getClient().getJobStatus(job.getPersistenceId()); - } while(submission.getStatus().isRunning()); - // Assert correct output assertTo( "1,1",
