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 <[email protected]> Authored: Tue Oct 6 15:35:59 2015 +0530 Committer: Rajat Khandelwal <[email protected]> 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());
