sqoop-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a..@apache.org
Subject sqoop git commit: SQOOP-2405: Sqoop2: Remove active wait in test cases after executeJob() call
Date Fri, 26 Jun 2015 17:46:25 GMT
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 <abe@apache.org>
Authored: Fri Jun 26 10:45:16 2015 -0700
Committer: Abraham Elmahrek <abe@apache.org>
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",


Mime
View raw message