sqoop-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jar...@apache.org
Subject git commit: SQOOP-1419: Sqoop2: From/To: Check TO connection is enabled
Date Wed, 13 Aug 2014 23:37:19 GMT
Repository: sqoop
Updated Branches:
  refs/heads/SQOOP-1367 28d765cd4 -> a8fb4df82


SQOOP-1419: Sqoop2: From/To: Check TO connection is enabled

(Abraham Elmahrek via Jarek Jarcec Cecho)


Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/a8fb4df8
Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/a8fb4df8
Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/a8fb4df8

Branch: refs/heads/SQOOP-1367
Commit: a8fb4df820fd17be884a6a51cdd4e6d50304fdfb
Parents: 28d765c
Author: Jarek Jarcec Cecho <jarcec@apache.org>
Authored: Wed Aug 13 16:36:53 2014 -0700
Committer: Jarek Jarcec Cecho <jarcec@apache.org>
Committed: Wed Aug 13 16:36:53 2014 -0700

----------------------------------------------------------------------
 core/src/main/java/org/apache/sqoop/framework/JobManager.java | 5 +++++
 1 file changed, 5 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/sqoop/blob/a8fb4df8/core/src/main/java/org/apache/sqoop/framework/JobManager.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/sqoop/framework/JobManager.java b/core/src/main/java/org/apache/sqoop/framework/JobManager.java
index d7d8962..ac82284 100644
--- a/core/src/main/java/org/apache/sqoop/framework/JobManager.java
+++ b/core/src/main/java/org/apache/sqoop/framework/JobManager.java
@@ -288,6 +288,11 @@ public class JobManager implements Reconfigurable {
         "Connection id: " + fromConnection.getPersistenceId());
     }
 
+    if (!toConnection.getEnabled()) {
+      throw new SqoopException(FrameworkError.FRAMEWORK_0010,
+          "Connection id: " + toConnection.getPersistenceId());
+    }
+
     SqoopConnector fromConnector =
       ConnectorManager.getInstance().getConnector(job.getConnectorId(ConnectorType.FROM));
     SqoopConnector toConnector =


Mime
View raw message