sqoop-commits mailing list archives

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 <jarcec@apache.org>
Authored: Mon Jan 4 18:41:10 2016 -0800
Committer: Jarek Jarcec Cecho <jarcec@apache.org>
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());
   }