apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vro...@apache.org
Subject incubator-apex-core git commit: Logging of proxy addresses at different computation stages for better debugging
Date Mon, 21 Mar 2016 21:38:19 GMT
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 <pramod@datatorrent.com>
Authored: Sun Mar 20 11:11:32 2016 -0700
Committer: Pramod Immaneni <pramod@datatorrent.com>
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) {


Mime
View raw message