You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ja...@apache.org on 2017/08/16 22:06:45 UTC
samza git commit: SAMZA-1397;
log.debug loop to run only if debug is enabled
Repository: samza
Updated Branches:
refs/heads/master 119e2fa01 -> 202af33bf
SAMZA-1397; log.debug loop to run only if debug is enabled
Author: Boris Shkolnik <bo...@apache.org>
Reviewers: Jagadish <jagadish@apache.org?
Closes #275 from sborya/LocalityLogDebug
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/202af33b
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/202af33b
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/202af33b
Branch: refs/heads/master
Commit: 202af33bfe7d60ec9b2f90854abffde4bd55d2e6
Parents: 119e2fa
Author: Boris Shkolnik <bo...@apache.org>
Authored: Wed Aug 16 15:08:51 2017 -0700
Committer: Jagadish <ja...@apache.org>
Committed: Wed Aug 16 15:08:51 2017 -0700
----------------------------------------------------------------------
.../main/java/org/apache/samza/container/LocalityManager.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/samza/blob/202af33b/samza-core/src/main/java/org/apache/samza/container/LocalityManager.java
----------------------------------------------------------------------
diff --git a/samza-core/src/main/java/org/apache/samza/container/LocalityManager.java b/samza-core/src/main/java/org/apache/samza/container/LocalityManager.java
index bafebcc..033002c 100644
--- a/samza-core/src/main/java/org/apache/samza/container/LocalityManager.java
+++ b/samza-core/src/main/java/org/apache/samza/container/LocalityManager.java
@@ -109,8 +109,10 @@ public class LocalityManager extends AbstractCoordinatorStreamManager {
}
containerToHostMapping = Collections.unmodifiableMap(allMappings);
- for (Map.Entry<String, Map<String, String>> entry : containerToHostMapping.entrySet()) {
- log.debug(String.format("Locality for container %s: %s", entry.getKey(), entry.getValue()));
+ if (log.isDebugEnabled()) {
+ for (Map.Entry<String, Map<String, String>> entry : containerToHostMapping.entrySet()) {
+ log.debug(String.format("Locality for container %s: %s", entry.getKey(), entry.getValue()));
+ }
}
return allMappings;