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 <pro...@apache.org> Authored: Thu Nov 3 11:50:04 2016 +0530 Committer: Amareshwari Sriramadasu <amareshw...@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); }