Repository: sqoop Updated Branches: refs/heads/sqoop2 0495bc7b4 -> 23781db25
SQOOP-2773: Sqoop2: Ensure that the connector-sdk-hadoop jar is shipped to mappers (Abraham Fine 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/23781db2 Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/23781db2 Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/23781db2 Branch: refs/heads/sqoop2 Commit: 23781db25febea4aabe4def2ce5697e401ad69ed Parents: 0495bc7 Author: Jarek Jarcec Cecho <[email protected]> Authored: Mon Jan 4 18:41:10 2016 -0800 Committer: Jarek Jarcec Cecho <[email protected]> Committed: Mon Jan 4 18:41:10 2016 -0800 ---------------------------------------------------------------------- core/pom.xml | 4 ++++ core/src/main/java/org/apache/sqoop/driver/JobManager.java | 5 ++++- 2 files changed, 8 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/23781db2/core/pom.xml ---------------------------------------------------------------------- diff --git a/core/pom.xml b/core/pom.xml index 0a8ec09..0cf3492 100644 --- a/core/pom.xml +++ b/core/pom.xml @@ -57,6 +57,10 @@ limitations under the License. <groupId>org.apache.sqoop</groupId> <artifactId>connector-sdk</artifactId> </dependency> + <dependency> + <groupId>org.apache.sqoop</groupId> + <artifactId>connector-sdk-hadoop</artifactId> + </dependency> </dependencies> <build> http://git-wip-us.apache.org/repos/asf/sqoop/blob/23781db2/core/src/main/java/org/apache/sqoop/driver/JobManager.java ---------------------------------------------------------------------- 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 6e1c999..61bde8b 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.Direction; 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 @@ public class JobManager implements Reconfigurable { 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()); }
