You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2018/09/21 16:30:42 UTC
[3/8] storm git commit: Merge branch 'master' of
https://git-wip-us.apache.org/repos/asf/storm
Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/storm
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/5c3a911c
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/5c3a911c
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/5c3a911c
Branch: refs/heads/master
Commit: 5c3a911c0aed922421f4fab387dfad550ec90b31
Parents: f991dae c8fab20
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Tue Feb 13 12:13:02 2018 -0500
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Tue Feb 13 12:13:02 2018 -0500
----------------------------------------------------------------------
docs/SECURITY.md | 6 +-
.../apache/storm/hive/bolt/TestHiveBolt.java | 33 +-
.../apache/storm/kafka/spout/KafkaSpout.java | 8 +-
storm-client/pom.xml | 2 +-
.../src/jvm/org/apache/storm/Config.java | 8 +
.../storm/cluster/ClusterStateContext.java | 22 +-
.../org/apache/storm/cluster/ClusterUtils.java | 58 +-
.../org/apache/storm/cluster/DaemonType.java | 90 ++-
.../storm/cluster/IStormClusterState.java | 67 +-
.../cluster/PaceMakerStateStorageFactory.java | 7 +-
.../storm/cluster/StateStorageFactory.java | 6 +-
.../storm/cluster/StormClusterStateImpl.java | 189 ++++-
.../apache/storm/cluster/ZKStateStorage.java | 4 +-
.../storm/cluster/ZKStateStorageFactory.java | 4 +-
.../org/apache/storm/daemon/worker/Worker.java | 35 +-
.../apache/storm/daemon/worker/WorkerState.java | 52 +-
.../jvm/org/apache/storm/executor/Executor.java | 4 +-
.../storm/executor/bolt/BoltExecutor.java | 21 +-
.../storm/generated/PrivateWorkerKey.java | 615 ++++++++++++++++
.../org/apache/storm/generated/WorkerToken.java | 638 +++++++++++++++++
.../apache/storm/generated/WorkerTokenInfo.java | 701 +++++++++++++++++++
.../storm/generated/WorkerTokenServiceType.java | 62 ++
.../grouping/LoadAwareShuffleGrouping.java | 35 +-
.../org/apache/storm/metric/api/IMetric.java | 6 +-
.../storm/metric/api/IMetricsRegistrant.java | 30 +
.../storm/security/INimbusCredentialPlugin.java | 7 +-
.../auth/AbstractSaslClientCallbackHandler.java | 76 --
.../auth/AbstractSaslServerCallbackHandler.java | 94 ---
.../apache/storm/security/auth/AuthUtils.java | 164 ++++-
.../storm/security/auth/ITransportPlugin.java | 12 +-
.../apache/storm/security/auth/ReqContext.java | 11 +
.../security/auth/SaslTransportPlugin.java | 187 -----
.../security/auth/SimpleTransportPlugin.java | 4 +-
.../storm/security/auth/ThriftClient.java | 2 +-
.../security/auth/ThriftConnectionType.java | 81 ++-
.../storm/security/auth/ThriftServer.java | 53 +-
.../auth/digest/ClientCallbackHandler.java | 58 --
.../auth/digest/DigestSaslTransportPlugin.java | 60 +-
.../auth/digest/JassPasswordProvider.java | 85 +++
.../auth/digest/ServerCallbackHandler.java | 85 ---
.../storm/security/auth/kerberos/AutoTGT.java | 73 +-
.../kerberos/KerberosSaslTransportPlugin.java | 73 +-
.../auth/kerberos/ServerCallbackHandler.java | 86 +--
.../auth/plain/PlainClientCallbackHandler.java | 16 +-
.../auth/plain/PlainSaslTransportPlugin.java | 18 +-
.../auth/plain/PlainServerCallbackHandler.java | 55 --
.../security/auth/plain/SaslPlainServer.java | 2 +
.../security/auth/sasl/PasswordProvider.java | 48 ++
.../security/auth/sasl/SaslTransportPlugin.java | 187 +++++
.../sasl/SimpleSaslClientCallbackHandler.java | 77 ++
.../sasl/SimpleSaslServerCallbackHandler.java | 189 +++++
.../auth/workertoken/WorkerTokenAuthorizer.java | 139 ++++
.../WorkerTokenClientCallbackHandler.java | 65 ++
.../auth/workertoken/WorkerTokenSigner.java | 63 ++
.../org/apache/storm/utils/ObjectReader.java | 12 +
.../src/jvm/org/apache/storm/utils/Utils.java | 39 +-
storm-client/src/py/storm/ttypes.py | 320 +++++++++
storm-client/src/storm.thrift | 41 +-
.../apache/storm/cluster/DaemonTypeTest.java | 78 +++
.../cluster/StormClusterStateImplTest.java | 18 +-
.../grouping/LoadAwareShuffleGroupingTest.java | 33 +-
.../security/auth/SaslTransportPluginTest.java | 1 +
.../org/apache/storm/command/AdminCommands.java | 24 +-
.../org/apache/storm/command/Heartbeats.java | 2 +-
.../test/clj/org/apache/storm/cluster_test.clj | 10 +-
.../test/clj/org/apache/storm/nimbus_test.clj | 47 +-
.../apache/storm/security/auth/auth_test.clj | 474 -------------
.../security/auth/jaas_digest_bad_password.conf | 31 -
.../auth/jaas_digest_missing_client.conf | 23 -
.../security/auth/jaas_digest_unknown_user.conf | 31 -
.../storm/security/auth/nimbus_auth_test.clj | 5 +-
storm-server/pom.xml | 2 +-
.../java/org/apache/storm/DaemonConfig.java | 10 +-
.../java/org/apache/storm/LocalCluster.java | 7 +-
.../src/main/java/org/apache/storm/Testing.java | 6 +-
.../org/apache/storm/daemon/nimbus/Nimbus.java | 76 +-
.../storm/daemon/supervisor/Supervisor.java | 24 +-
.../daemon/supervisor/SupervisorUtils.java | 7 -
.../auth/workertoken/WorkerTokenManager.java | 126 ++++
.../apache/storm/security/auth/AuthTest.java | 637 +++++++++++++++++
.../auth/workertoken/WorkerTokenTest.java | 159 +++++
.../src/test/resources/jaas_digest.conf | 30 +
.../resources/jaas_digest_bad_password.conf | 31 +
.../resources/jaas_digest_missing_client.conf | 23 +
.../resources/jaas_digest_unknown_user.conf | 31 +
85 files changed, 5550 insertions(+), 1581 deletions(-)
----------------------------------------------------------------------