diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/mr/HadoopJobExecHelper.java ql/src/java/org/apache/hadoop/hive/ql/exec/mr/HadoopJobExecHelper.java index b0e6ef3..0a2f976 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/mr/HadoopJobExecHelper.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/mr/HadoopJobExecHelper.java @@ -503,7 +503,7 @@ public int progressLocal(Process runningJob, String taskId) { } } else { console.printInfo("Execution completed successfully"); - console.printInfo("Mapred Local Task Succeeded . Convert the Join into MapJoin"); + console.printInfo("MapredLocal task succeeded"); } return exitVal; } diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/mr/MapredLocalTask.java ql/src/java/org/apache/hadoop/hive/ql/exec/mr/MapredLocalTask.java index 341154d..5c2b0fd 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/mr/MapredLocalTask.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/mr/MapredLocalTask.java @@ -271,7 +271,6 @@ public int execute(DriverContext driverContext) { } } else { LOG.info("Execution completed successfully"); - console.printInfo("Mapred Local Task Succeeded . Convert the Join into MapJoin"); } return exitVal;