Fixed to use hive.query.id for JobId (in Tez/Hive)

myui · Sep 4, 2014 · 7431248 · 7431248
1 parent c186617
commit 7431248
Show file tree

Hide file tree

Showing 4 changed files with 3 additions and 3 deletions.
diff --git a/src/main/hivemall/utils/hadoop/HadoopUtils.java b/src/main/hivemall/utils/hadoop/HadoopUtils.java
@@ -110,9 +110,9 @@ public static String getJobId() {
         if(jobId == null) {
             jobId = conf.get("mapreduce.job.id");
             if(jobId == null) {
-                String appId = conf.get("mapreduce.tez.session.tokill-application-id");
-                if(appId != null) {
-                    return appId;
+                String queryId = conf.get("hive.query.id");
+                if(queryId != null) {
+                    return queryId;
                 }
                 String taskidStr = conf.get("mapred.task.id");
                 if(taskidStr == null) {

diff --git a/target/hivemall-fat.jar b/target/hivemall-fat.jar
diff --git a/target/hivemall-with-dependencies.jar b/target/hivemall-with-dependencies.jar
diff --git a/target/hivemall.jar b/target/hivemall.jar