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 2017/01/18 12:19:20 UTC
lens git commit: LENS-1370 : Fix purging queries which are before
retry framework
Repository: lens
Updated Branches:
refs/heads/master 4fb250619 -> 5ac688048
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/master
Commit: 5ac688048ef2f8a233f022311dd8bbbd07aa0757
Parents: 4fb2506
Author: Rajat Khandelwal <pr...@apache.org>
Authored: Wed Jan 18 17:49:07 2017 +0530
Committer: Amareshwari Sriramadasu <am...@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 {