hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From x..@apache.org
Subject hive git commit: HIVE-11314: Print "Execution completed successfully" as part of spark job info [Spark Branch](Ferdinand Xu, reviewed by Xuefu Zhang)
Date Tue, 21 Jul 2015 05:42:49 GMT
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 <cheng.a.xu@intel.com>
Authored: Tue Jul 21 01:42:08 2015 -0400
Committer: Ferdinand Xu <cheng.a.xu@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();
       }


Mime
View raw message