diff --git a/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/MapreduceSubmissionEngine.java b/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/MapreduceSubmissionEngine.java
index 02db3652..0e8c9f72 100644
--- a/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/MapreduceSubmissionEngine.java
+++ b/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/MapreduceSubmissionEngine.java
@@ -424,6 +424,12 @@ private Counters convertMapreduceCounters(org.apache.hadoop.mapred.Counters hado
    * @return True if we're running in local mode
    */
   private boolean isLocal() {
+    // If framework is set to YARN, then we can't be running in local mode
+    if("yarn".equals(globalConfiguration.get("mapreduce.framework.name"))) {
+      return false;
+    }
+
+    // If job tracker address is "local" then we're running in local mode
     return "local".equals(globalConfiguration.get("mapreduce.jobtracker.address"))
         || "local".equals(globalConfiguration.get("mapred.job.tracker"));
   }