diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/spark/status/SparkJobMonitor.java ql/src/java/org/apache/hadoop/hive/ql/exec/spark/status/SparkJobMonitor.java index b092abc..1157a66 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/spark/status/SparkJobMonitor.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/spark/status/SparkJobMonitor.java @@ -88,7 +88,10 @@ public int startMonitor() { } console.printInfo("\nStatus: Running (Hive on Spark job[" + - sparkJobStatus.getJobId() + "])\n"); + sparkJobStatus.getJobId() + "])"); + console.printInfo("Progress format\n" + + "stageId_stageAttemptId: " + + "succeedTasksCount(+runningTasksCount-failedTasksCount)/totalTasksCount\n"); startTime = System.currentTimeMillis(); running = true; }