diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java index 814213d..15e2b95 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java @@ -208,9 +208,8 @@ public static MapredWork getMapRedWork(Configuration job) { assert jobID != null; gWork = gWorkMap.get(jobID); if (gWork == null) { - String jtConf = ShimLoader.getHadoopShims().getJobLauncherRpcAddress(job); String path; - if (jtConf.equals("local")) { + if (ShimLoader.getHadoopShims().isLocalMode(job)) { String planPath = HiveConf.getVar(job, HiveConf.ConfVars.PLAN); path = new Path(planPath).toUri().getPath(); } else {