From b1fcbc9d934e33a9579a4a5aa0a93968645bc4d6 Mon Sep 17 00:00:00 2001 From: Kate Ting Date: Sat, 11 May 2013 21:22:20 -0400 Subject: [PATCH] SQOOP-1002: Sqoop2: Mapreduce local mode detection is not working correctly on Hadoop 2.x (Jarek Jarcec Cecho via Kate Ting) --- .../submission/mapreduce/MapreduceSubmissionEngine.java | 6 ++++++ 1 file changed, 6 insertions(+) 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")); }