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 =