From 1d4b9e96cfeee6dc8fbdf223c36c964f25c30c60 Mon Sep 17 00:00:00 2001 From: Jarek Jarcec Cecho Date: Wed, 13 Aug 2014 16:36:53 -0700 Subject: [PATCH] SQOOP-1419: Sqoop2: From/To: Check TO connection is enabled (Abraham Elmahrek via Jarek Jarcec Cecho) --- .../src/main/java/org/apache/sqoop/framework/JobManager.java | 5 +++++ 1 file changed, 5 insertions(+) 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 d7d89624..ac82284c 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 MSubmission submit(long jobId, HttpEventContext ctx) { "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 =