You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by xu...@apache.org on 2015/07/21 07:42:49 UTC
hive git commit: HIVE-11314: Print "Execution completed successfully"
as part of spark job info [Spark Branch](Ferdinand Xu,
reviewed by Xuefu Zhang)
Repository: hive
Updated Branches:
refs/heads/spark ab9b18dc8 -> fb7ba8bde
HIVE-11314: Print "Execution completed successfully" as part of spark job info [Spark Branch](Ferdinand Xu, reviewed by Xuefu Zhang)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/fb7ba8bd
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/fb7ba8bd
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/fb7ba8bd
Branch: refs/heads/spark
Commit: fb7ba8bdeebdc53d584538b8936941764b5d9a7d
Parents: ab9b18d
Author: Ferdinand Xu <ch...@intel.com>
Authored: Tue Jul 21 01:42:08 2015 -0400
Committer: Ferdinand Xu <ch...@intel.com>
Committed: Tue Jul 21 01:42:08 2015 -0400
----------------------------------------------------------------------
ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkTask.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/fb7ba8bd/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkTask.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkTask.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkTask.java
index 62e91ba..a36dc6e 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkTask.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkTask.java
@@ -118,6 +118,7 @@ public class SparkTask extends Task<SparkWork> {
LOG.info(String.format("=====Spark Job[%s] statistics=====", jobRef.getJobId()));
logSparkStatistic(sparkStatistics);
}
+ LOG.info("Execution completed successfully");
} else if (rc == 2) { // Cancel job if the monitor found job submission timeout.
jobRef.cancelJob();
}