You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lens.apache.org by pu...@apache.org on 2016/08/01 08:44:42 UTC
[42/50] [abbrv] lens git commit: LENS-955 : Fix test failure
TestQueryEndEmailNotifier.testLaunchFailure
LENS-955 : Fix test failure TestQueryEndEmailNotifier.testLaunchFailure
Project: http://git-wip-us.apache.org/repos/asf/lens/repo
Commit: http://git-wip-us.apache.org/repos/asf/lens/commit/1924bbb0
Tree: http://git-wip-us.apache.org/repos/asf/lens/tree/1924bbb0
Diff: http://git-wip-us.apache.org/repos/asf/lens/diff/1924bbb0
Branch: refs/heads/current-release-line
Commit: 1924bbb018cbb4aa7cf8c0b2cf11376a053e3b9d
Parents: c5dd7de
Author: Amareshwari Sriramadasu <am...@apache.org>
Authored: Tue Jul 26 16:15:59 2016 +0530
Committer: Amareshwari Sriramadasu <am...@apache.org>
Committed: Tue Jul 26 16:15:59 2016 +0530
----------------------------------------------------------------------
.../server/query/QueryExecutionServiceImpl.java | 23 ++++++++++----------
1 file changed, 12 insertions(+), 11 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lens/blob/1924bbb0/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 a582994..4df2b9b 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
@@ -2049,17 +2049,18 @@ public class QueryExecutionServiceImpl extends BaseLensService implements QueryE
}
private QueryHandle submitQuery(final QueryContext ctx) throws LensException {
-
- QueryStatus before = ctx.getStatus();
- ctx.setStatus(new QueryStatus(0.0, null, QUEUED, "Query is queued", false, null, null, null));
- queuedQueries.add(ctx);
- log.debug("Added to Queued Queries:{}", ctx.getQueryHandleString());
- allQueries.put(ctx.getQueryHandle(), ctx);
- // Add to session's active query list
- getSession(SESSION_MAP.get(ctx.getLensSessionIdentifier())).addToActiveQueries(ctx.getQueryHandle());
- fireStatusChangeEvent(ctx, ctx.getStatus(), before);
- log.info("Returning handle {}", ctx.getQueryHandle().getHandleId());
- return ctx.getQueryHandle();
+ synchronized (ctx) {
+ QueryStatus before = ctx.getStatus();
+ ctx.setStatus(new QueryStatus(0.0, null, QUEUED, "Query is queued", false, null, null, null));
+ queuedQueries.add(ctx);
+ log.info("Added to Queued Queries:{}", ctx.getQueryHandleString());
+ allQueries.put(ctx.getQueryHandle(), ctx);
+ // Add to session's active query list
+ getSession(SESSION_MAP.get(ctx.getLensSessionIdentifier())).addToActiveQueries(ctx.getQueryHandle());
+ fireStatusChangeEvent(ctx, ctx.getStatus(), before);
+ log.info("Returning handle {}", ctx.getQueryHandle().getHandleId());
+ return ctx.getQueryHandle();
+ }
}
/*