You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lens.apache.org by ra...@apache.org on 2015/10/09 06:17:48 UTC
[43/50] [abbrv] lens git commit: LENS-792: Improve StatusPoller
logging to reduce noise
LENS-792: Improve StatusPoller logging to reduce noise
Project: http://git-wip-us.apache.org/repos/asf/lens/repo
Commit: http://git-wip-us.apache.org/repos/asf/lens/commit/2ecef112
Tree: http://git-wip-us.apache.org/repos/asf/lens/tree/2ecef112
Diff: http://git-wip-us.apache.org/repos/asf/lens/diff/2ecef112
Branch: refs/heads/current-release-line
Commit: 2ecef112f49aa45521a4b5a81802d265d0e34129
Parents: 5c9bae0
Author: Rajat Khandelwal <pr...@apache.org>
Authored: Tue Oct 6 15:35:59 2015 +0530
Committer: Rajat Khandelwal <ra...@gmail.com>
Committed: Tue Oct 6 15:35:59 2015 +0530
----------------------------------------------------------------------
.../main/java/org/apache/lens/server/api/query/QueryContext.java | 3 +++
.../org/apache/lens/server/query/QueryExecutionServiceImpl.java | 4 ++--
2 files changed, 5 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lens/blob/2ecef112/lens-server-api/src/main/java/org/apache/lens/server/api/query/QueryContext.java
----------------------------------------------------------------------
diff --git a/lens-server-api/src/main/java/org/apache/lens/server/api/query/QueryContext.java b/lens-server-api/src/main/java/org/apache/lens/server/api/query/QueryContext.java
index 3a5b887..ac94207 100644
--- a/lens-server-api/src/main/java/org/apache/lens/server/api/query/QueryContext.java
+++ b/lens-server-api/src/main/java/org/apache/lens/server/api/query/QueryContext.java
@@ -43,11 +43,13 @@ import com.google.common.collect.Lists;
import lombok.Getter;
import lombok.Setter;
import lombok.ToString;
+import lombok.extern.slf4j.Slf4j;
/**
* The Class QueryContext.
*/
@ToString
+@Slf4j
public class QueryContext extends AbstractQueryContext {
/**
@@ -334,6 +336,7 @@ public class QueryContext extends AbstractQueryContext {
public synchronized void setStatus(final QueryStatus newStatus) throws LensException {
validateTransition(newStatus);
+ log.info("Updating status of {} from {} to {}", getQueryHandle(), this.status, newStatus);
this.status = newStatus;
}
http://git-wip-us.apache.org/repos/asf/lens/blob/2ecef112/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 ea19742..73179e1 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
@@ -670,7 +670,7 @@ public class QueryExecutionServiceImpl extends BaseLensService implements QueryE
}
logSegregationContext.setLogSegragationAndQueryId(ctx.getQueryHandleString());
- log.info("Polling status for {}", ctx.getQueryHandle());
+ log.debug("Polling status for {}", ctx.getQueryHandle());
try {
// session is not required to update status of the query
// don't need to wrap this with acquire/release
@@ -770,7 +770,7 @@ public class QueryExecutionServiceImpl extends BaseLensService implements QueryE
synchronized (ctx) {
QueryStatus before = ctx.getStatus();
if (!ctx.queued() && !ctx.finished() && !ctx.getDriverStatus().isFinished()) {
- log.info("Updating status for {}", ctx.getQueryHandle());
+ log.debug("Updating status for {}", ctx.getQueryHandle());
try {
ctx.getSelectedDriver().updateStatus(ctx);
ctx.setStatus(ctx.getDriverStatus().toQueryStatus());