From 7edaa11d22bedb5597db7c01ed2ddd2d6532e934 Mon Sep 17 00:00:00 2001 From: Abraham Elmahrek Date: Fri, 26 Jun 2015 10:45:16 -0700 Subject: [PATCH] SQOOP-2405: Sqoop2: Remove active wait in test cases after executeJob() call (Banmeet Singh via Abraham Elmahrek) --- .../jdbc/generic/FromRDBMSToHDFSTest.java | 32 ------------------- 1 file changed, 32 deletions(-) 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 1272ed98..dac6db79 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 void testStories() throws Exception { 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 void testColumns() throws Exception { 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 void testSql() throws Exception { 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 void testDuplicateColumns() throws Exception { 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",