You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sr...@apache.org on 2015/04/01 05:35:16 UTC
[1/3] storm git commit: STORM-741: Allow users to pass a config value
to perform impersonation.
Repository: storm
Updated Branches:
refs/heads/master bc530b46b -> db6df0caf
STORM-741: Allow users to pass a config value to perform impersonation.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/bb968c83
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/bb968c83
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/bb968c83
Branch: refs/heads/master
Commit: bb968c8304e72d90d3d3d11c9fad66122f94dca7
Parents: 36e99fa
Author: Parth Brahmbhatt <br...@gmail.com>
Authored: Tue Mar 31 14:24:30 2015 -0700
Committer: Parth Brahmbhatt <br...@gmail.com>
Committed: Tue Mar 31 17:26:31 2015 -0700
----------------------------------------------------------------------
storm-core/src/jvm/backtype/storm/Config.java | 6 ++++++
storm-core/src/jvm/backtype/storm/utils/NimbusClient.java | 7 +++++++
2 files changed, 13 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/bb968c83/storm-core/src/jvm/backtype/storm/Config.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/Config.java b/storm-core/src/jvm/backtype/storm/Config.java
index 9cddb2e..e6032f1 100644
--- a/storm-core/src/jvm/backtype/storm/Config.java
+++ b/storm-core/src/jvm/backtype/storm/Config.java
@@ -1228,6 +1228,12 @@ public class Config extends HashMap<String, Object> {
public static final Object TRANSACTIONAL_ZOOKEEPER_PORT_SCHEMA = ConfigValidation.IntegerValidator;
/**
+ * The user as which the nimbus client should be acquired to perform the operation.
+ */
+ public static final String STORM_DO_AS_USER="storm.doAsUser";
+ public static final Object STORM_DO_AS_USER_SCHEMA = String.class;
+
+ /**
* The number of threads that should be used by the zeromq context in each worker process.
*/
public static final String ZMQ_THREADS = "zmq.threads";
http://git-wip-us.apache.org/repos/asf/storm/blob/bb968c83/storm-core/src/jvm/backtype/storm/utils/NimbusClient.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/utils/NimbusClient.java b/storm-core/src/jvm/backtype/storm/utils/NimbusClient.java
index b171353..6314deb 100644
--- a/storm-core/src/jvm/backtype/storm/utils/NimbusClient.java
+++ b/storm-core/src/jvm/backtype/storm/utils/NimbusClient.java
@@ -42,6 +42,13 @@ public class NimbusClient extends ThriftClient {
public static NimbusClient getConfiguredClientAs(Map conf, String asUser) {
try {
+ if(conf.containsKey(Config.STORM_DO_AS_USER)) {
+ if(asUser != null && !asUser.isEmpty()) {
+ LOG.warn("You have specified a doAsUser as param {} and a doAsParam as config, config will take precedence."
+ , asUser, conf.get(Config.STORM_DO_AS_USER));
+ }
+ asUser = (String) conf.get(Config.STORM_DO_AS_USER);
+ }
String nimbusHost = (String) conf.get(Config.NIMBUS_HOST);
return new NimbusClient(conf, nimbusHost, null, null, asUser);
} catch (TTransportException ex) {
[2/3] storm git commit: Merge branch 'STORM-741' of
https://github.com/Parth-Brahmbhatt/incubator-storm into STORM-741
Posted by sr...@apache.org.
Merge branch 'STORM-741' of https://github.com/Parth-Brahmbhatt/incubator-storm into STORM-741
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/003f08d2
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/003f08d2
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/003f08d2
Branch: refs/heads/master
Commit: 003f08d2d0d224c68d620ded35ae2bebc8cfa810
Parents: bc530b4 bb968c8
Author: Sriharsha Chintalapani <ha...@hortonworks.com>
Authored: Tue Mar 31 20:23:37 2015 -0700
Committer: Sriharsha Chintalapani <ha...@hortonworks.com>
Committed: Tue Mar 31 20:23:37 2015 -0700
----------------------------------------------------------------------
storm-core/src/jvm/backtype/storm/Config.java | 6 ++++++
storm-core/src/jvm/backtype/storm/utils/NimbusClient.java | 7 +++++++
2 files changed, 13 insertions(+)
----------------------------------------------------------------------
[3/3] storm git commit: Added STORM-741 to CHANGELOG.
Posted by sr...@apache.org.
Added STORM-741 to CHANGELOG.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/db6df0ca
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/db6df0ca
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/db6df0ca
Branch: refs/heads/master
Commit: db6df0cafaada08c79679b828721336263341c6c
Parents: 003f08d
Author: Sriharsha Chintalapani <ha...@hortonworks.com>
Authored: Tue Mar 31 20:24:15 2015 -0700
Committer: Sriharsha Chintalapani <ha...@hortonworks.com>
Committed: Tue Mar 31 20:24:15 2015 -0700
----------------------------------------------------------------------
CHANGELOG.md | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/db6df0ca/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index c0de063..a81810e 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,4 +1,5 @@
## 0.11.0
+ * STORM-741: Allow users to pass a config value to perform impersonation.
* STORM-724: Document RedisStoreBolt and RedisLookupBolt which is missed.
* STORM-711: All connectors should use collector.reportError and tuple anchoring.
* STORM-714: Make CSS more consistent with self, prev release