Repository: samza Updated Branches: refs/heads/master 119e2fa01 -> 202af33bf
SAMZA-1397; log.debug loop to run only if debug is enabled Author: Boris Shkolnik <[email protected]> Reviewers: Jagadish <[email protected]? 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 <[email protected]> Authored: Wed Aug 16 15:08:51 2017 -0700 Committer: Jagadish <[email protected]> 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;
