You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by et...@apache.org on 2019/08/22 19:19:32 UTC

[storm] branch master updated (7ea9235 -> b9fcb19)

This is an automated email from the ASF dual-hosted git repository.

ethanli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git.


    from 7ea9235  Merge pull request #3108 from RuiLi8080/STORM-3492
     add b9fcb19  STORM-3434: server: fix all checkstyle warnings (#3050)

No new revisions were added by this update.

Summary of changes:
 .../storm/scheduler/multitenant_scheduler_test.clj |  48 +--
 .../nimbus/InMemoryTopologyActionNotifier.java     |   2 +-
 storm-server/pom.xml                               |   2 +-
 .../main/java/org/apache/storm/DaemonConfig.java   |  41 +-
 .../storm/ILocalClusterTrackedTopologyAware.java   |   5 +-
 .../main/java/org/apache/storm/LocalCluster.java   |  68 ++--
 .../src/main/java/org/apache/storm/LocalDRPC.java  |   5 +-
 .../java/org/apache/storm/ProcessSimulator.java    |  15 +-
 .../src/main/java/org/apache/storm/Testing.java    | 221 +++++-----
 .../org/apache/storm/blobstore/BlobStoreUtils.java |   3 +-
 .../apache/storm/blobstore/FileBlobStoreImpl.java  |  26 +-
 .../apache/storm/blobstore/KeySequenceNumber.java  | 106 ++---
 .../apache/storm/blobstore/LocalFsBlobStore.java   |  77 ++--
 .../storm/blobstore/LocalFsBlobStoreFile.java      |  68 ++--
 .../container/ResourceIsolationInterface.java      |   3 +-
 .../daemon/drpc/BlockingOutstandingRequest.java    |  30 +-
 .../java/org/apache/storm/daemon/drpc/DRPC.java    |  39 +-
 .../org/apache/storm/daemon/drpc/DRPCThrift.java   |  15 +-
 .../storm/daemon/drpc/OutstandingRequest.java      |  24 +-
 .../apache/storm/daemon/drpc/RequestFactory.java   |   3 +-
 .../org/apache/storm/daemon/nimbus/Nimbus.java     | 443 +++++++++++----------
 .../org/apache/storm/daemon/nimbus/TopoCache.java  |   5 +-
 .../storm/daemon/nimbus/TopologyActions.java       |   2 +-
 .../storm/daemon/nimbus/TopologyResources.java     |   4 +
 .../daemon/nimbus/TopologyStateTransition.java     |   3 +-
 .../storm/daemon/supervisor/BasicContainer.java    | 340 ++++++++--------
 .../daemon/supervisor/BasicContainerLauncher.java  |  30 +-
 .../apache/storm/daemon/supervisor/Container.java  | 291 +++++++-------
 .../storm/daemon/supervisor/ContainerLauncher.java |   6 +-
 .../daemon/supervisor/ContainerMemoryTracker.java  |  13 +-
 .../apache/storm/daemon/supervisor/Killable.java   |   9 +-
 .../storm/daemon/supervisor/LocalContainer.java    |  20 +-
 .../daemon/supervisor/LocalContainerLauncher.java  |  20 +-
 .../daemon/supervisor/OnlyLatestExecutor.java      |   2 +-
 .../storm/daemon/supervisor/ReadClusterState.java  |  20 +-
 .../daemon/supervisor/RunAsUserContainer.java      |  14 +-
 .../supervisor/RunAsUserContainerLauncher.java     |  28 +-
 .../org/apache/storm/daemon/supervisor/Slot.java   |  85 ++--
 .../apache/storm/daemon/supervisor/Supervisor.java |   8 +-
 .../storm/daemon/supervisor/SupervisorUtils.java   |  21 +-
 .../org/apache/storm/localizer/AsyncLocalizer.java |  88 ++--
 .../storm/localizer/BlobChangingCallback.java      |   2 +-
 .../java/org/apache/storm/localizer/GoodToGo.java  |   1 +
 .../org/apache/storm/localizer/IOFunction.java     |   2 +
 .../apache/storm/localizer/LocalizedResource.java  |   2 +-
 .../localizer/LocalizedResourceRetentionSet.java   |   1 +
 .../storm/localizer/LocallyCachedTopologyBlob.java |  11 +-
 .../metric/ClusterMetricsConsumerExecutor.java     |  11 +-
 .../metric/LoggingClusterMetricsConsumer.java      |  18 +-
 .../metricstore/rocksdb/RocksDbMetricsWriter.java  |   6 +-
 .../storm/metricstore/rocksdb/RocksDbStore.java    |  15 +-
 .../metricstore/rocksdb/StringMetadataCache.java   |   4 +-
 .../rocksdb/WritableStringMetadataCache.java       |   4 +-
 .../nimbus/AssignmentDistributionService.java      |   1 -
 .../storm/nimbus/DefaultTopologyValidator.java     |   2 +-
 .../nimbus/ITopologyActionNotifierPlugin.java      |   8 +-
 .../apache/storm/nimbus/ITopologyValidator.java    |   2 +-
 .../storm/nimbus/LeaderListenerCallback.java       |   5 +-
 .../TimeOutWorkerHeartbeatsRecoveryStrategy.java   |   4 +-
 .../apache/storm/pacemaker/PacemakerServer.java    |  15 +-
 .../pacemaker/codec/ThriftNettyServerCodec.java    |  46 +--
 .../java/org/apache/storm/scheduler/Cluster.java   |   4 +-
 .../org/apache/storm/scheduler/ISupervisor.java    |   1 +
 .../apache/storm/scheduler/IsolationScheduler.java |   8 +-
 .../org/apache/storm/scheduler/Topologies.java     |   8 +-
 .../apache/storm/scheduler/TopologyDetails.java    |   3 +-
 .../scheduler/blacklist/BlacklistScheduler.java    |   6 +-
 .../blacklist/strategies/RasBlacklistStrategy.java |   2 +-
 .../storm/scheduler/multitenant/DefaultPool.java   |  97 +++--
 .../storm/scheduler/multitenant/FreePool.java      |  28 +-
 .../storm/scheduler/multitenant/IsolatedPool.java  | 146 ++++---
 .../apache/storm/scheduler/multitenant/Node.java   | 161 ++++----
 .../storm/scheduler/multitenant/NodePool.java      | 127 +++---
 .../resource/{RAS_Node.java => RasNode.java}       |  10 +-
 .../resource/{RAS_Nodes.java => RasNodes.java}     |  26 +-
 .../scheduler/resource/ResourceAwareScheduler.java |   2 +-
 .../DefaultSchedulingPriorityStrategy.java         |   4 +-
 .../priority/FIFOSchedulingPriorityStrategy.java   |   5 +-
 .../scheduling/BaseResourceAwareStrategy.java      |  50 +--
 .../scheduling/ConstraintSolverStrategy.java       |  46 +--
 .../scheduler/utils/ArtifactoryConfigLoader.java   |  35 +-
 .../auth/DefaultHttpCredentialsPlugin.java         |   2 +-
 .../security/auth/IHttpCredentialsPlugin.java      |   5 +-
 .../storm/security/auth/ServerAuthUtils.java       |   4 +-
 .../auth/workertoken/WorkerTokenManager.java       |   6 +-
 .../java/org/apache/storm/stats/StatsUtil.java     |  13 +-
 .../storm/testing/CompleteTopologyParam.java       |  10 +-
 .../apache/storm/testing/InProcessZookeeper.java   |   1 +
 .../java/org/apache/storm/testing/TestJob.java     |   2 +-
 .../org/apache/storm/testing/TrackedTopology.java  |  39 +-
 .../org/apache/storm/utils/ServerConfigUtils.java  |   8 +-
 .../java/org/apache/storm/utils/ServerUtils.java   |  81 ++--
 .../apache/storm/utils/StormCommonInstaller.java   |  10 +-
 .../storm/utils/ZookeeperServerCnxnFactory.java    |  35 +-
 .../org/apache/storm/zookeeper/AclEnforcement.java |   4 +-
 .../java/org/apache/storm/zookeeper/Zookeeper.java |  12 +-
 .../daemon/supervisor/BasicContainerTest.java      |   8 +-
 .../resource/TestResourceAwareScheduler.java       |   6 +-
 .../TestDefaultResourceAwareStrategy.java          |   6 +-
 99 files changed, 1756 insertions(+), 1678 deletions(-)
 rename storm-server/src/main/java/org/apache/storm/scheduler/resource/{RAS_Node.java => RasNode.java} (98%)
 rename storm-server/src/main/java/org/apache/storm/scheduler/resource/{RAS_Nodes.java => RasNodes.java} (89%)