LENS-1370 : Fix purging queries which are before retry framework
Project: http://git-wip-us.apache.org/repos/asf/lens/repo Commit: http://git-wip-us.apache.org/repos/asf/lens/commit/5ac68804 Tree: http://git-wip-us.apache.org/repos/asf/lens/tree/5ac68804 Diff: http://git-wip-us.apache.org/repos/asf/lens/diff/5ac68804 Branch: refs/heads/lens-1381 Commit: 5ac688048ef2f8a233f022311dd8bbbd07aa0757 Parents: 4fb2506 Author: Rajat Khandelwal <pro...@apache.org> Authored: Wed Jan 18 17:49:07 2017 +0530 Committer: Amareshwari Sriramadasu <amareshw...@apache.org> Committed: Wed Jan 18 17:49:07 2017 +0530 ---------------------------------------------------------------------- .../main/java/org/apache/lens/server/query/LensServerDAO.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/lens/blob/5ac68804/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 dd489e8..cc6ca7d 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 @@ -139,8 +139,10 @@ public class LensServerDAO { query.getDriverEndTime(), query.getDriverName(), query.getQueryName(), query.getSubmissionTime(), 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); + if (query.getFailedAttempts() != null) { + for (int i = 0; i < query.getFailedAttempts().size(); i++) { + insertFailedAttempt(runner, conn, query.getHandle(), query.getFailedAttempts().get(i), i); + } } conn.commit(); } finally {
