diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java index edb55fa..c39389b 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java @@ -260,9 +260,8 @@ public static BaseWork getBaseWork(Configuration conf, String name) { assert path != null; gWork = gWorkMap.get(path); if (gWork == null) { - String jtConf = ShimLoader.getHadoopShims().getJobLauncherRpcAddress(conf); Path localPath; - if (jtConf.equals("local")) { + if (ShimLoader.getHadoopShims().isLocalMode(conf)) { localPath = path; } else { localPath = new Path(name);