Repository: incubator-apex-core Updated Branches: refs/heads/master 6130bca38 -> 9eba29de8
Logging of proxy addresses at different computation stages for better debugging Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/9eba29de Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/9eba29de Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/9eba29de Branch: refs/heads/master Commit: 9eba29de8143efd716aba8d2a4bdb085e298ab5a Parents: 6130bca Author: Pramod Immaneni <[email protected]> Authored: Sun Mar 20 11:11:32 2016 -0700 Committer: Pramod Immaneni <[email protected]> Committed: Sun Mar 20 11:11:32 2016 -0700 ---------------------------------------------------------------------- .../datatorrent/stram/security/StramWSFilterInitializer.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/9eba29de/engine/src/main/java/com/datatorrent/stram/security/StramWSFilterInitializer.java ---------------------------------------------------------------------- diff --git a/engine/src/main/java/com/datatorrent/stram/security/StramWSFilterInitializer.java b/engine/src/main/java/com/datatorrent/stram/security/StramWSFilterInitializer.java index e9870c6..b090d09 100644 --- a/engine/src/main/java/com/datatorrent/stram/security/StramWSFilterInitializer.java +++ b/engine/src/main/java/com/datatorrent/stram/security/StramWSFilterInitializer.java @@ -24,14 +24,14 @@ import java.util.Collection; import java.util.HashMap; import java.util.Map; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.http.FilterContainer; import org.apache.hadoop.http.FilterInitializer; import org.apache.hadoop.yarn.conf.YarnConfiguration; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - import com.datatorrent.stram.client.StramClientUtils; import com.datatorrent.stram.util.ConfigUtils; @@ -59,9 +59,11 @@ public class StramWSFilterInitializer extends FilterInitializer for (String rmId : ConfigUtils.getRMHAIds(conf)) { proxies.add(getResolvedRMWebAppURLWithoutScheme(conf, rmId)); } + logger.info("HA proxy addresses {}", proxies); } if (proxies.isEmpty()) { proxies.add(getProxyHostAndPort(conf)); + logger.info("Proxy addresses {}", proxies); } StringBuilder proxyBr = new StringBuilder(); for (String proxy : proxies) {
