diff --git a/src/java/com/cloudera/sqoop/mapreduce/JobBase.java b/src/java/com/cloudera/sqoop/mapreduce/JobBase.java
index 37483d04..4aae092a 100644
--- a/src/java/com/cloudera/sqoop/mapreduce/JobBase.java
+++ b/src/java/com/cloudera/sqoop/mapreduce/JobBase.java
@@ -140,6 +140,7 @@ protected void cacheJars(Job job, ConnManager mgr)
     addToCache(Jars.getSqoopJarPath(), fs, localUrls);
     addToCache(Jars.getShimJarPath(), fs, localUrls);
     addToCache(Jars.getDriverClassJar(mgr), fs, localUrls);
+    addToCache(Jars.getJarPathForClass(mgr.getClass()), fs, localUrls);
 
     // Add anything in $SQOOP_HOME/lib, if this is set.
     String sqoopHome = System.getenv("SQOOP_HOME");