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/04/12 14:33:47 UTC
lens git commit: LENS-918 : Fix setting log seggregation id for
rewriteAndSelect
Repository: lens
Updated Branches:
refs/heads/master 09fc9d1a3 -> 33dfee1d6
LENS-918 : Fix setting log seggregation id for rewriteAndSelect
Project: http://git-wip-us.apache.org/repos/asf/lens/repo
Commit: http://git-wip-us.apache.org/repos/asf/lens/commit/33dfee1d
Tree: http://git-wip-us.apache.org/repos/asf/lens/tree/33dfee1d
Diff: http://git-wip-us.apache.org/repos/asf/lens/diff/33dfee1d
Branch: refs/heads/master
Commit: 33dfee1d6c50b7f90ff835b99c1d4633f6bb9032
Parents: 09fc9d1
Author: Ajay Yadava <aj...@apache.org>
Authored: Tue Apr 12 18:03:32 2016 +0530
Committer: Amareshwari Sriramadasu <am...@apache.org>
Committed: Tue Apr 12 18:03:32 2016 +0530
----------------------------------------------------------------------
.../org/apache/lens/server/query/QueryExecutionServiceImpl.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lens/blob/33dfee1d/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 ad39028..42bd4ab 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
@@ -1334,6 +1334,7 @@ public class QueryExecutionServiceImpl extends BaseLensService implements QueryE
* @throws LensException the lens exception
*/
private void rewriteAndSelect(final AbstractQueryContext ctx) throws LensException {
+ logSegregationContext.setLogSegragationAndQueryId(ctx.getLogHandle());
MethodMetricsContext parallelCallGauge = MethodMetricsFactory.createMethodGauge(ctx.getConf(), false,
PARALLEL_CALL_GAUGE);
try {