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 <[email protected]> Authored: Wed Aug 13 16:36:53 2014 -0700 Committer: Jarek Jarcec Cecho <[email protected]> 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 =
