You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sqoop.apache.org by ja...@apache.org on 2014/08/14 01:37:19 UTC
git commit: SQOOP-1419: Sqoop2: From/To: Check TO connection is
enabled
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 <ja...@apache.org>
Authored: Wed Aug 13 16:36:53 2014 -0700
Committer: Jarek Jarcec Cecho <ja...@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 =