You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lens.apache.org by am...@apache.org on 2015/05/21 11:48:56 UTC
incubator-lens git commit: LENS-339 : Fix setting endTime for query
upon restart (Rajat Khandelwal via amareshwari)
Repository: incubator-lens
Updated Branches:
refs/heads/master 76638a1fb -> 1d82fd76d
LENS-339 : Fix setting endTime for query upon restart (Rajat Khandelwal via amareshwari)
Project: http://git-wip-us.apache.org/repos/asf/incubator-lens/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-lens/commit/1d82fd76
Tree: http://git-wip-us.apache.org/repos/asf/incubator-lens/tree/1d82fd76
Diff: http://git-wip-us.apache.org/repos/asf/incubator-lens/diff/1d82fd76
Branch: refs/heads/master
Commit: 1d82fd76d77dd9ae15839519576c3bbdd0993223
Parents: 76638a1
Author: Rajat Khandelwal <pr...@apache.org>
Authored: Thu May 21 15:18:30 2015 +0530
Committer: Amareshwari Sriramadasu <am...@apache.org>
Committed: Thu May 21 15:18:30 2015 +0530
----------------------------------------------------------------------
.../apache/lens/server/query/QueryExecutionServiceImpl.java | 8 ++++++--
1 file changed, 6 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-lens/blob/1d82fd76/lens-server/src/main/java/org/apache/lens/server/query/QueryExecutionServiceImpl.java
----------------------------------------------------------------------
diff --git a/lens-server/src/main/java/org/apache/lens/server/query/QueryExecutionServiceImpl.java b/lens-server/src/main/java/org/apache/lens/server/query/QueryExecutionServiceImpl.java
index 3bf180c..343cd01 100644
--- a/lens-server/src/main/java/org/apache/lens/server/query/QueryExecutionServiceImpl.java
+++ b/lens-server/src/main/java/org/apache/lens/server/query/QueryExecutionServiceImpl.java
@@ -411,8 +411,12 @@ public class QueryExecutionServiceImpl extends LensService implements QueryExecu
*/
FinishedQuery(QueryContext ctx) {
this.ctx = ctx;
- this.finishTime = new Date();
- ctx.setEndTime(this.finishTime.getTime());
+ if (ctx.getEndTime() == 0) {
+ this.finishTime = new Date();
+ ctx.setEndTime(this.finishTime.getTime());
+ } else {
+ this.finishTime = new Date(ctx.getEndTime());
+ }
}
/*