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 <[email protected]>
Authored: Thu May 21 15:18:30 2015 +0530
Committer: Amareshwari Sriramadasu <[email protected]>
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());
+      }
     }
 
     /*

Reply via email to