You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2016/08/23 08:03:15 UTC
[8/9] storm git commit: Merge branch 'STORM-2016'
Merge branch 'STORM-2016'
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/51f52fe8
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/51f52fe8
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/51f52fe8
Branch: refs/heads/master
Commit: 51f52fe8d67d7aed6adcaf1ce5bf47e6261b5204
Parents: abad445 3fee2bd
Author: Jungtaek Lim <ka...@gmail.com>
Authored: Tue Aug 23 17:01:08 2016 +0900
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Tue Aug 23 17:01:08 2016 +0900
----------------------------------------------------------------------
bin/storm.py | 143 +-
docs/Command-line-client.md | 24 +-
external/storm-submit-tools/pom.xml | 199 +++
.../submit/command/DependencyResolverMain.java | 105 ++
.../storm/submit/dependency/AetherUtils.java | 81 ++
.../apache/storm/submit/dependency/Booter.java | 63 +
.../submit/dependency/DependencyResolver.java | 70 +
.../dependency/RepositorySystemFactory.java | 66 +
.../submit/dependency/AetherUtilsTest.java | 102 ++
.../dependency/DependencyResolverTest.java | 78 ++
pom.xml | 5 +
.../src/clj/org/apache/storm/daemon/nimbus.clj | 14 +-
.../jvm/org/apache/storm/StormSubmitter.java | 106 +-
.../apache/storm/blobstore/BlobStoreUtils.java | 21 +-
.../org/apache/storm/daemon/StormCommon.java | 4 +-
.../daemon/supervisor/SyncSupervisorEvent.java | 101 +-
.../workermanager/DefaultWorkerManager.java | 23 +-
.../dependency/DependencyPropertiesParser.java | 61 +
.../storm/dependency/DependencyUploader.java | 166 +++
.../dependency/FileNotAvailableException.java | 33 +
.../org/apache/storm/generated/Assignment.java | 244 ++--
.../org/apache/storm/generated/BoltStats.java | 406 +++---
.../apache/storm/generated/ClusterSummary.java | 108 +-
.../storm/generated/ClusterWorkerHeartbeat.java | 52 +-
.../storm/generated/ComponentPageInfo.java | 220 +--
.../org/apache/storm/generated/Credentials.java | 44 +-
.../apache/storm/generated/ExecutorStats.java | 168 +--
.../jvm/org/apache/storm/generated/HBNodes.java | 32 +-
.../org/apache/storm/generated/HBRecords.java | 36 +-
.../storm/generated/LSApprovedWorkers.java | 44 +-
.../generated/LSSupervisorAssignments.java | 48 +-
.../apache/storm/generated/LSTopoHistory.java | 64 +-
.../storm/generated/LSTopoHistoryList.java | 36 +-
.../storm/generated/LSWorkerHeartbeat.java | 36 +-
.../apache/storm/generated/ListBlobsResult.java | 32 +-
.../apache/storm/generated/LocalAssignment.java | 36 +-
.../apache/storm/generated/LocalStateData.java | 48 +-
.../org/apache/storm/generated/LogConfig.java | 48 +-
.../jvm/org/apache/storm/generated/Nimbus.java | 36 +-
.../org/apache/storm/generated/NodeInfo.java | 32 +-
.../storm/generated/RebalanceOptions.java | 44 +-
.../storm/generated/SettableBlobMeta.java | 36 +-
.../org/apache/storm/generated/SpoutStats.java | 252 ++--
.../org/apache/storm/generated/StormBase.java | 92 +-
.../apache/storm/generated/StormTopology.java | 428 +++++-
.../apache/storm/generated/SupervisorInfo.java | 152 +-
.../storm/generated/SupervisorPageInfo.java | 76 +-
.../storm/generated/SupervisorSummary.java | 44 +-
.../storm/generated/TopologyHistoryInfo.java | 32 +-
.../apache/storm/generated/TopologyInfo.java | 160 +--
.../storm/generated/TopologyPageInfo.java | 132 +-
.../apache/storm/generated/TopologyStats.java | 220 +--
.../jvm/org/apache/storm/utils/ConfigUtils.java | 11 +-
.../apache/storm/utils/ThriftTopologyUtils.java | 4 +
.../src/jvm/org/apache/storm/utils/Utils.java | 6 +-
storm-core/src/py/storm/Nimbus.py | 14 +-
storm-core/src/py/storm/ttypes.py | 1302 +++++++++---------
storm-core/src/storm.thrift | 12 +-
.../test/clj/org/apache/storm/nimbus_test.clj | 27 +-
.../clj/org/apache/storm/supervisor_test.clj | 18 +-
.../DependencyPropertiesParserTest.java | 72 +
.../dependency/DependencyUploaderTest.java | 297 ++++
.../storm/utils/ThriftTopologyUtilsTest.java | 12 +
.../staticmocking/ConfigUtilsInstaller.java | 2 +
storm-dist/binary/src/main/assembly/binary.xml | 7 +
65 files changed, 4403 insertions(+), 2284 deletions(-)
----------------------------------------------------------------------