diff --git a/core/pom.xml b/core/pom.xml index 0a8ec097..0cf34929 100644 --- a/core/pom.xml +++ b/core/pom.xml @@ -57,6 +57,10 @@ limitations under the License. org.apache.sqoop connector-sdk + + org.apache.sqoop + connector-sdk-hadoop + diff --git a/core/src/main/java/org/apache/sqoop/driver/JobManager.java b/core/src/main/java/org/apache/sqoop/driver/JobManager.java index 6e1c999b..61bde8b1 100644 --- a/core/src/main/java/org/apache/sqoop/driver/JobManager.java +++ b/core/src/main/java/org/apache/sqoop/driver/JobManager.java @@ -29,6 +29,7 @@ import org.apache.sqoop.common.MapContext; import org.apache.sqoop.common.SqoopException; import org.apache.sqoop.connector.ConnectorManager; +import org.apache.sqoop.connector.hadoop.security.SecurityUtils; import org.apache.sqoop.connector.idf.IntermediateDataFormat; import org.apache.sqoop.connector.spi.SqoopConnector; import org.apache.sqoop.core.ConfigurationConstants; @@ -443,8 +444,10 @@ private void addStandardJars(JobRequest jobRequest) { jobRequest.addJarForClass(MapContext.class); // sqoop-core jobRequest.addJarForClass(Driver.class); - // sqoop-spi + // connector-sdk jobRequest.addJarForClass(SqoopConnector.class); + // connector-sdk-hadoop + jobRequest.addJarForClass(SecurityUtils.class); // Execution engine jar jobRequest.addJarForClass(executionEngine.getClass()); }