You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@carbondata.apache.org by ra...@apache.org on 2016/08/06 10:00:27 UTC
[10/20] incubator-carbondata git commit: [CARBONDATA-137] Fixed
detail limit query statistics issue (#904)
[CARBONDATA-137] Fixed detail limit query statistics issue (#904)
In case of detail query with limit it total query execution time in statistics is printing negative values as wrong method is getting called
Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/b4ae2eb7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/b4ae2eb7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/b4ae2eb7
Branch: refs/heads/master
Commit: b4ae2eb73b6dbc6f25717bfeaa9c5f55fb471c21
Parents: d70a6e5
Author: Kumar Vishal <ku...@gmail.com>
Authored: Thu Aug 4 12:55:42 2016 +0530
Committer: Venkata Ramana G <g....@gmail.com>
Committed: Thu Aug 4 12:55:42 2016 +0530
----------------------------------------------------------------------
.../src/main/scala/org/carbondata/spark/rdd/CarbonQueryRDD.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/b4ae2eb7/integration/spark/src/main/scala/org/carbondata/spark/rdd/CarbonQueryRDD.scala
----------------------------------------------------------------------
diff --git a/integration/spark/src/main/scala/org/carbondata/spark/rdd/CarbonQueryRDD.scala b/integration/spark/src/main/scala/org/carbondata/spark/rdd/CarbonQueryRDD.scala
index 9eb680c..8a545e8 100644
--- a/integration/spark/src/main/scala/org/carbondata/spark/rdd/CarbonQueryRDD.scala
+++ b/integration/spark/src/main/scala/org/carbondata/spark/rdd/CarbonQueryRDD.scala
@@ -232,7 +232,7 @@ class CarbonQueryRDD[V: ClassTag](
if (null != queryModel.getStatisticsRecorder) {
val queryStatistic = new QueryStatistic
queryStatistic
- .addStatistics("Total Time taken to execute the query in executor Side",
+ .addFixedTimeStatistic("Total Time taken to execute the query in executor Side",
System.currentTimeMillis - queryStartTime
)
queryModel.getStatisticsRecorder.recordStatistics(queryStatistic);
@@ -253,7 +253,7 @@ class CarbonQueryRDD[V: ClassTag](
if (null != queryModel.getStatisticsRecorder) {
val queryStatistic = new QueryStatistic
queryStatistic
- .addStatistics("Total Time taken to execute the query in executor Side",
+ .addFixedTimeStatistic("Total Time taken to execute the query in executor Side",
System.currentTimeMillis - queryStartTime
)
queryModel.getStatisticsRecorder.recordStatistics(queryStatistic);