You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ranger.apache.org by ve...@apache.org on 2016/12/22 13:43:36 UTC

incubator-ranger git commit: RANGER-1242:TestConnectionForStormService

Repository: incubator-ranger
Updated Branches:
  refs/heads/master 62689c3c8 -> fda9a01d0


RANGER-1242:TestConnectionForStormService

Signed-off-by: Velmurugan Periasamy <ve...@apache.org>


Project: http://git-wip-us.apache.org/repos/asf/incubator-ranger/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ranger/commit/fda9a01d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ranger/tree/fda9a01d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ranger/diff/fda9a01d

Branch: refs/heads/master
Commit: fda9a01d049cd6c4c2b8eb525514293e4b2dc785
Parents: 62689c3
Author: zhangqiang2 <zh...@zte.com.cn>
Authored: Wed Dec 7 16:25:31 2016 +0800
Committer: Velmurugan Periasamy <ve...@apache.org>
Committed: Thu Dec 22 08:25:16 2016 -0500

----------------------------------------------------------------------
 .../java/org/apache/ranger/services/storm/client/StormClient.java   | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ranger/blob/fda9a01d/storm-agent/src/main/java/org/apache/ranger/services/storm/client/StormClient.java
----------------------------------------------------------------------
diff --git a/storm-agent/src/main/java/org/apache/ranger/services/storm/client/StormClient.java b/storm-agent/src/main/java/org/apache/ranger/services/storm/client/StormClient.java
index d7415c5..0e9c0df 100644
--- a/storm-agent/src/main/java/org/apache/ranger/services/storm/client/StormClient.java
+++ b/storm-agent/src/main/java/org/apache/ranger/services/storm/client/StormClient.java
@@ -183,6 +183,7 @@ public class StormClient {
 		try {
 			ret = executeUnderKerberos(this.userName, this.password, this.lookupPrincipal, this.lookupKeytab, this.nameRules, topologyListGetter);
 		} catch (IOException e) {
+			ret=null;
 			LOG.error("Unable to get Topology list from [" + stormUIUrl + "]", e);
 		}