Index: ql/src/java/org/apache/hadoop/hive/ql/exec/Task.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/exec/Task.java (revision 1042755) +++ ql/src/java/org/apache/hadoop/hive/ql/exec/Task.java (working copy) @@ -61,6 +61,7 @@ protected Task backupTask; protected List> backupChildrenTasks = new ArrayList>(); protected int taskTag; + private boolean isLocalMode =false; public static final int NO_TAG = 0; public static final int COMMON_JOIN = 1; @@ -463,4 +464,12 @@ public void setTaskTag(int taskTag) { this.taskTag = taskTag; } + + public boolean isLocalMode() { + return isLocalMode; + } + + public void setLocalMode(boolean isLocalMode) { + this.isLocalMode = isLocalMode; + } } Index: ql/src/java/org/apache/hadoop/hive/ql/exec/MapRedTask.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/exec/MapRedTask.java (revision 1042755) +++ ql/src/java/org/apache/hadoop/hive/ql/exec/MapRedTask.java (working copy) @@ -106,8 +106,10 @@ cloneConf(); conf.setVar(HiveConf.ConfVars.HADOOPJT, "local"); console.printInfo("Selecting local mode for task: " + getId()); + this.setLocalMode(true); } else { console.printInfo("Cannot run job locally: " + reason); + this.setLocalMode(false); } }