You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2014/11/25 06:17:27 UTC
spark git commit: [SQL] Compute timeTaken correctly
Repository: spark
Updated Branches:
refs/heads/master 9ce2bf382 -> 723be60e2
[SQL] Compute timeTaken correctly
```timeTaken``` should not count the time of printing result.
Author: w00228970 <wa...@huawei.com>
Closes #3423 from scwf/time-taken-bug and squashes the following commits:
da7e102 [w00228970] compute time taken correctly
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/723be60e
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/723be60e
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/723be60e
Branch: refs/heads/master
Commit: 723be60e233d0f85944d948efd06845ef546c9f5
Parents: 9ce2bf3
Author: w00228970 <wa...@huawei.com>
Authored: Mon Nov 24 21:17:24 2014 -0800
Committer: Reynold Xin <rx...@databricks.com>
Committed: Mon Nov 24 21:17:24 2014 -0800
----------------------------------------------------------------------
.../spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala | 11 ++++-------
1 file changed, 4 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/723be60e/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala
----------------------------------------------------------------------
diff --git a/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala b/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala
index 2cd02ae..7385952 100755
--- a/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala
+++ b/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala
@@ -272,8 +272,10 @@ private[hive] class SparkSQLCLIDriver extends CliDriver with Logging {
if (sessionState.getIsVerbose) {
out.println(cmd)
}
-
val rc = driver.run(cmd)
+ val end = System.currentTimeMillis()
+ val timeTaken:Double = (end - start) / 1000.0
+
ret = rc.getResponseCode
if (ret != 0) {
console.printError(rc.getErrorMessage())
@@ -309,12 +311,7 @@ private[hive] class SparkSQLCLIDriver extends CliDriver with Logging {
ret = cret
}
- val end = System.currentTimeMillis()
- if (end > start) {
- val timeTaken:Double = (end - start) / 1000.0
- console.printInfo(s"Time taken: $timeTaken seconds", null)
- }
-
+ console.printInfo(s"Time taken: $timeTaken seconds", null)
// Destroy the driver to release all the locks.
driver.destroy()
} else {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org