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 2016/11/03 06:20:30 UTC
lens git commit: LENS-1370 : Fix Queries persisted before retry
framework upgrade are not getting purged
Repository: lens
Updated Branches:
refs/heads/master 9b0a453de -> 3c23f18c2
LENS-1370 : Fix Queries persisted before retry framework upgrade are not getting purged
Project: http://git-wip-us.apache.org/repos/asf/lens/repo
Commit: http://git-wip-us.apache.org/repos/asf/lens/commit/3c23f18c
Tree: http://git-wip-us.apache.org/repos/asf/lens/tree/3c23f18c
Diff: http://git-wip-us.apache.org/repos/asf/lens/diff/3c23f18c
Branch: refs/heads/master
Commit: 3c23f18c22aeacd891acd9ef7b7900e53c0015f1
Parents: 9b0a453
Author: Rajat Khandelwal <pr...@apache.org>
Authored: Thu Nov 3 11:50:04 2016 +0530
Committer: Amareshwari Sriramadasu <am...@apache.org>
Committed: Thu Nov 3 11:50:04 2016 +0530
----------------------------------------------------------------------
.../src/main/java/org/apache/lens/server/query/LensServerDAO.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lens/blob/3c23f18c/lens-server/src/main/java/org/apache/lens/server/query/LensServerDAO.java
----------------------------------------------------------------------
diff --git a/lens-server/src/main/java/org/apache/lens/server/query/LensServerDAO.java b/lens-server/src/main/java/org/apache/lens/server/query/LensServerDAO.java
index 3ab3aef..dd489e8 100644
--- a/lens-server/src/main/java/org/apache/lens/server/query/LensServerDAO.java
+++ b/lens-server/src/main/java/org/apache/lens/server/query/LensServerDAO.java
@@ -137,7 +137,8 @@ public class LensServerDAO {
query.getStartTime(), query.getEndTime(), query.getResult(), query.getStatus(), query.getMetadata(),
query.getRows(), query.getFileSize(), query.getErrorMessage(), query.getDriverStartTime(),
query.getDriverEndTime(), query.getDriverName(), query.getQueryName(), query.getSubmissionTime(),
- query.getDriverQuery(), serializeConf(query.getConf()), query.getFailedAttempts().size());
+ query.getDriverQuery(), serializeConf(query.getConf()),
+ query.getFailedAttempts() == null ? 0 : query.getFailedAttempts().size());
for (int i = 0; i < query.getFailedAttempts().size(); i++) {
insertFailedAttempt(runner, conn, query.getHandle(), query.getFailedAttempts().get(i), i);
}