github/sqoop
5
0
Fork 0
mirror of https://github.com/apache/sqoop.git synced 2025-05-07 03:01:15 +08:00
Code Issues Projects Releases Wiki Activity

SQOOP-2773: Sqoop2: Ensure that the connector-sdk-hadoop jar is shipped to mappers

Browse Source 
(Abraham Fine via Jarek Jarcec Cecho)
This commit is contained in:
Jarek Jarcec Cecho 2016-01-04 18:41:10 -08:00
parent 0495bc7b4d
commit 23781db25f
2 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
core/pom.xml
View File

@ -57,6 +57,10 @@ limitations under the License.
<groupId>org.apache.sqoop</groupId> <groupId>org.apache.sqoop</groupId>
<artifactId>connector-sdk</artifactId> <artifactId>connector-sdk</artifactId>
</dependency> </dependency>
<dependency>
<groupId>org.apache.sqoop</groupId>
<artifactId>connector-sdk-hadoop</artifactId>
</dependency>
</dependencies> </dependencies>
<build> <build>

5
core/src/main/java/org/apache/sqoop/driver/JobManager.java
View File

@ -29,6 +29,7 @@
import org.apache.sqoop.common.MapContext; import org.apache.sqoop.common.MapContext;
import org.apache.sqoop.common.SqoopException; import org.apache.sqoop.common.SqoopException;
import org.apache.sqoop.connector.ConnectorManager; 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.idf.IntermediateDataFormat;
import org.apache.sqoop.connector.spi.SqoopConnector; import org.apache.sqoop.connector.spi.SqoopConnector;
import org.apache.sqoop.core.ConfigurationConstants; import org.apache.sqoop.core.ConfigurationConstants;
@ -443,8 +444,10 @@ private void addStandardJars(JobRequest jobRequest) {
jobRequest.addJarForClass(MapContext.class); jobRequest.addJarForClass(MapContext.class);
// sqoop-core // sqoop-core
jobRequest.addJarForClass(Driver.class); jobRequest.addJarForClass(Driver.class);
// sqoop-spi // connector-sdk
jobRequest.addJarForClass(SqoopConnector.class); jobRequest.addJarForClass(SqoopConnector.class);
// connector-sdk-hadoop
jobRequest.addJarForClass(SecurityUtils.class);
// Execution engine jar // Execution engine jar
jobRequest.addJarForClass(executionEngine.getClass()); jobRequest.addJarForClass(executionEngine.getClass());
} }