This is an automated email from the ASF dual-hosted git repository. reiabreu pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/storm.git
commit 9c737f65fa2d0c4ad6ea5d6eb8a5eabddbb70171 Merge: b9f9b182a 4705aadde Author: reiabreu <[email protected]> AuthorDate: Sat Oct 24 01:18:33 2026 +0100 Merge pull request #9184 from sercuzz8/checkstyle-fix/storm-client-39331264304-1 Checkstyle auto-fix of storm-client storm-client/src/jvm/org/apache/storm/Config.java | 1477 +++++++++++++------- .../src/jvm/org/apache/storm/Constants.java | 28 +- .../src/jvm/org/apache/storm/ILocalCluster.java | 20 +- .../src/jvm/org/apache/storm/ILocalDRPC.java | 4 +- .../src/jvm/org/apache/storm/ISubmitterHook.java | 9 +- .../src/jvm/org/apache/storm/LogWriter.java | 1 - .../src/jvm/org/apache/storm/StormSubmitter.java | 180 ++- .../src/jvm/org/apache/storm/StormTimer.java | 43 +- storm-client/src/jvm/org/apache/storm/Thrift.java | 37 +- .../storm/annotation/InterfaceStability.java | 9 +- .../assignments/ILocalAssignmentsBackend.java | 3 +- .../assignments/InMemoryAssignmentBackend.java | 9 +- .../LocalAssignmentsBackendFactory.java | 8 +- .../jvm/org/apache/storm/blobstore/BlobStore.java | 71 +- .../storm/blobstore/BlobStoreAclHandler.java | 68 +- .../apache/storm/blobstore/ClientBlobStore.java | 37 +- .../storm/blobstore/LocalModeClientBlobStore.java | 15 +- .../apache/storm/blobstore/NimbusBlobStore.java | 33 +- .../src/jvm/org/apache/storm/bolt/JoinBolt.java | 105 +- .../storm/callback/DefaultWatcherCallBack.java | 6 +- .../apache/storm/cluster/ClusterStateContext.java | 3 +- .../jvm/org/apache/storm/cluster/ClusterUtils.java | 45 +- .../jvm/org/apache/storm/cluster/DaemonType.java | 19 +- .../org/apache/storm/cluster/IStateStorage.java | 67 +- .../apache/storm/cluster/IStormClusterState.java | 51 +- .../storm/cluster/PaceMakerStateStorage.java | 39 +- .../cluster/PaceMakerStateStorageFactory.java | 9 +- .../apache/storm/cluster/StateStorageFactory.java | 3 +- .../storm/cluster/StormClusterStateImpl.java | 183 ++- .../org/apache/storm/cluster/ZKStateStorage.java | 37 +- .../storm/cluster/ZKStateStorageFactory.java | 3 +- .../storm/container/cgroup/CgroupCenter.java | 5 +- .../storm/container/cgroup/CgroupCommon.java | 30 +- .../container/cgroup/CgroupCommonOperation.java | 18 +- .../storm/container/cgroup/CgroupOperation.java | 19 +- .../apache/storm/container/cgroup/CgroupUtils.java | 5 +- .../org/apache/storm/container/cgroup/Device.java | 2 +- .../apache/storm/container/cgroup/Hierarchy.java | 4 +- .../apache/storm/container/cgroup/SubSystem.java | 4 +- .../storm/container/cgroup/SubSystemType.java | 1 - .../storm/container/cgroup/SystemOperation.java | 5 +- .../storm/container/cgroup/core/BlkioCore.java | 51 +- .../storm/container/cgroup/core/CpuCore.java | 30 +- .../storm/container/cgroup/core/CpuacctCore.java | 6 +- .../storm/container/cgroup/core/CpusetCore.java | 63 +- .../storm/container/cgroup/core/DevicesCore.java | 6 +- .../storm/container/cgroup/core/FreezerCore.java | 6 +- .../storm/container/cgroup/core/MemoryCore.java | 54 +- .../storm/container/cgroup/core/NetClsCore.java | 3 +- .../storm/container/cgroup/core/NetPrioCore.java | 9 +- .../storm/coordination/BatchBoltExecutor.java | 4 +- .../storm/coordination/BatchOutputCollector.java | 3 +- .../coordination/BatchSubtopologyBuilder.java | 25 +- .../apache/storm/coordination/CoordinatedBolt.java | 38 +- .../org/apache/storm/coordination/IBatchBolt.java | 3 +- .../src/jvm/org/apache/storm/daemon/Acker.java | 6 +- .../org/apache/storm/daemon/GrouperFactory.java | 38 +- .../jvm/org/apache/storm/daemon/StormCommon.java | 213 +-- .../src/jvm/org/apache/storm/daemon/Task.java | 99 +- .../apache/storm/daemon/common/FileWatcher.java | 6 +- .../storm/daemon/metrics/BuiltinMetricsUtil.java | 12 +- .../storm/daemon/metrics/ClientMetricsUtils.java | 4 +- .../storm/daemon/supervisor/AdvancedFSOps.java | 43 +- .../daemon/supervisor/ClientSupervisorUtils.java | 34 +- .../storm/daemon/supervisor/IAdvancedFSOps.java | 14 +- .../storm/daemon/worker/BackPressureTracker.java | 28 +- .../storm/daemon/worker/LogConfigManager.java | 12 +- .../jvm/org/apache/storm/daemon/worker/Worker.java | 275 ++-- .../apache/storm/daemon/worker/WorkerState.java | 248 ++-- .../apache/storm/daemon/worker/WorkerTransfer.java | 31 +- .../storm/dependency/DependencyBlobStoreUtils.java | 9 +- .../storm/dependency/DependencyUploader.java | 31 +- .../apache/storm/drpc/DRPCInvocationsClient.java | 9 +- .../src/jvm/org/apache/storm/drpc/DRPCSpout.java | 68 +- .../src/jvm/org/apache/storm/drpc/JoinResult.java | 4 +- .../jvm/org/apache/storm/drpc/KeyedFairBolt.java | 6 +- .../storm/drpc/LinearDRPCTopologyBuilder.java | 32 +- .../jvm/org/apache/storm/drpc/PrepareRequest.java | 1 - .../jvm/org/apache/storm/drpc/ReturnResults.java | 8 +- .../org/apache/storm/executor/ChildEwmaStats.java | 20 +- .../apache/storm/executor/EwmaFeedbackRecord.java | 3 +- .../jvm/org/apache/storm/executor/Executor.java | 203 +-- .../apache/storm/executor/ExecutorShutdown.java | 26 +- .../apache/storm/executor/ExecutorTransfer.java | 42 +- .../org/apache/storm/executor/LocalExecutor.java | 11 +- .../jvm/org/apache/storm/executor/TupleInfo.java | 2 +- .../apache/storm/executor/bolt/BoltExecutor.java | 31 +- .../executor/bolt/BoltOutputCollectorImpl.java | 29 +- .../apache/storm/executor/error/ReportError.java | 11 +- .../storm/executor/error/ReportErrorAndDie.java | 2 +- .../apache/storm/executor/spout/SpoutExecutor.java | 71 +- .../executor/spout/SpoutOutputCollectorImpl.java | 28 +- .../storm/grouping/CustomStreamGrouping.java | 6 +- .../storm/grouping/JitterAwareStreamGrouping.java | 48 +- .../src/jvm/org/apache/storm/grouping/Load.java | 14 +- .../storm/grouping/LoadAwareShuffleGrouping.java | 63 +- .../jvm/org/apache/storm/grouping/LoadMapping.java | 6 +- .../apache/storm/grouping/PartialKeyGrouping.java | 45 +- .../org/apache/storm/grouping/ShuffleGrouping.java | 4 +- .../jvm/org/apache/storm/hooks/BaseWorkerHook.java | 5 +- .../jvm/org/apache/storm/hooks/IWorkerHook.java | 20 +- .../apache/storm/hooks/SubmitterHookException.java | 3 +- .../org/apache/storm/hooks/info/BoltAckInfo.java | 1 - .../apache/storm/hooks/info/BoltExecuteInfo.java | 1 - .../org/apache/storm/hooks/info/BoltFailInfo.java | 1 - .../org/apache/storm/hooks/info/SpoutAckInfo.java | 1 - .../org/apache/storm/hooks/info/SpoutFailInfo.java | 1 - .../apache/storm/lambda/LambdaBiConsumerBolt.java | 3 +- .../jvm/org/apache/storm/lambda/LambdaSpout.java | 3 +- .../storm/messaging/ConnectionWithStatus.java | 11 +- .../messaging/DeserializingConnectionCallback.java | 70 +- .../messaging/FatalDeserializationException.java | 6 +- .../org/apache/storm/messaging/IConnection.java | 5 +- .../jvm/org/apache/storm/messaging/IContext.java | 9 +- .../apache/storm/messaging/TransportFactory.java | 19 +- .../org/apache/storm/messaging/local/Context.java | 33 +- .../storm/messaging/netty/BackPressureStatus.java | 9 +- .../messaging/netty/BackPressureStatusEncoder.java | 5 +- .../org/apache/storm/messaging/netty/Client.java | 135 +- .../org/apache/storm/messaging/netty/Context.java | 29 +- .../storm/messaging/netty/ControlMessage.java | 3 +- .../storm/messaging/netty/INettySerializable.java | 1 + .../org/apache/storm/messaging/netty/IServer.java | 3 +- .../messaging/netty/KerberosSaslClientHandler.java | 45 +- .../messaging/netty/KerberosSaslNettyClient.java | 25 +- .../messaging/netty/KerberosSaslNettyServer.java | 27 +- .../messaging/netty/KerberosSaslServerHandler.java | 39 +- .../org/apache/storm/messaging/netty/Login.java | 133 +- .../apache/storm/messaging/netty/MessageBatch.java | 13 +- .../storm/messaging/netty/MessageDecoder.java | 17 +- .../messaging/netty/NettyRenameThreadFactory.java | 3 +- .../netty/NettySerializableMessageEncoder.java | 16 +- .../storm/messaging/netty/NettyTlsUtils.java | 54 +- .../netty/NettyUncaughtExceptionHandler.java | 3 +- .../storm/messaging/netty/SaslMessageToken.java | 5 +- .../storm/messaging/netty/SaslNettyClient.java | 35 +- .../messaging/netty/SaslNettyClientState.java | 3 +- .../storm/messaging/netty/SaslNettyServer.java | 31 +- .../messaging/netty/SaslNettyServerState.java | 3 +- .../messaging/netty/SaslStormClientHandler.java | 50 +- .../netty/SaslStormServerAuthorizeHandler.java | 25 +- .../messaging/netty/SaslStormServerHandler.java | 43 +- .../apache/storm/messaging/netty/SaslUtils.java | 6 +- .../org/apache/storm/messaging/netty/Server.java | 76 +- .../storm/messaging/netty/StormClientHandler.java | 25 +- .../netty/StormClientPipelineFactory.java | 15 +- .../storm/messaging/netty/StormServerHandler.java | 18 +- .../netty/StormServerPipelineFactory.java | 12 +- .../org/apache/storm/metric/EventLoggerBolt.java | 29 +- .../apache/storm/metric/FileBasedEventLogger.java | 12 +- .../jvm/org/apache/storm/metric/IEventLogger.java | 11 +- .../storm/metric/LoggingMetricsConsumer.java | 19 +- .../apache/storm/metric/MetricsConsumerBolt.java | 24 +- .../jvm/org/apache/storm/metric/SystemBolt.java | 25 +- .../jvm/org/apache/storm/metric/api/IMetric.java | 8 +- .../apache/storm/metric/api/IMetricsConsumer.java | 10 +- .../org/apache/storm/metric/api/MeanReducer.java | 4 +- .../storm/metric/api/rpc/CountShellMetric.java | 3 +- .../org/apache/storm/metric/cgroup/CGroupCpu.java | 5 +- .../storm/metric/cgroup/CGroupCpuGuarantee.java | 5 +- .../cgroup/CGroupCpuGuaranteeByCfsQuota.java | 6 +- .../storm/metric/cgroup/CGroupMemoryLimit.java | 2 +- .../storm/metric/cgroup/CGroupMetricsBase.java | 38 +- .../storm/metric/filter/FilterByMetricName.java | 13 +- .../apache/storm/metric/internal/CountStat.java | 22 +- .../apache/storm/metric/internal/LatencyStat.java | 31 +- .../storm/metric/internal/MultiCountStat.java | 7 +- .../apache/storm/metric/internal/RateTracker.java | 19 +- .../storm/metric/util/DataPointExpander.java | 6 +- .../apache/storm/metrics2/DimensionalReporter.java | 25 +- .../jvm/org/apache/storm/metrics2/EwmaGauge.java | 1 - .../jvm/org/apache/storm/metrics2/RateCounter.java | 13 +- .../apache/storm/metrics2/StormMetricRegistry.java | 170 ++- .../storm/metrics2/TaskMetricDimensions.java | 3 +- .../org/apache/storm/metrics2/TaskMetricRepo.java | 9 +- .../jvm/org/apache/storm/metrics2/TaskMetrics.java | 17 +- .../storm/metrics2/cgroup/CGroupCpuGuarantee.java | 3 +- .../cgroup/CGroupCpuGuaranteeByCfsQuota.java | 6 +- .../storm/metrics2/cgroup/CGroupCpuStat.java | 1 - .../storm/metrics2/cgroup/CGroupMemoryLimit.java | 2 +- .../storm/metrics2/cgroup/CGroupMetricsBase.java | 34 +- .../apache/storm/metrics2/filters/RegexFilter.java | 1 - .../storm/metrics2/filters/StormMetricsFilter.java | 3 +- .../metrics2/reporters/ConsoleStormReporter.java | 17 +- .../storm/metrics2/reporters/CsvStormReporter.java | 11 +- .../metrics2/reporters/GraphiteStormReporter.java | 8 +- .../storm/metrics2/reporters/JmxStormReporter.java | 10 +- .../metrics2/reporters/ScheduledStormReporter.java | 7 +- .../storm/metrics2/reporters/StormReporter.java | 7 +- .../jvm/org/apache/storm/multilang/BoltMsg.java | 9 +- .../org/apache/storm/multilang/ISerializer.java | 5 +- .../org/apache/storm/multilang/JsonSerializer.java | 9 +- .../jvm/org/apache/storm/multilang/ShellMsg.java | 13 +- .../jvm/org/apache/storm/multilang/SpoutMsg.java | 9 +- .../AbstractDNSToSwitchMapping.java | 25 +- .../networktopography/DNSToSwitchMapping.java | 18 +- .../DefaultRackDNSToSwitchMapping.java | 8 +- .../org/apache/storm/nimbus/ILeaderElector.java | 18 +- .../jvm/org/apache/storm/nimbus/NimbusInfo.java | 18 +- .../apache/storm/pacemaker/PacemakerClient.java | 52 +- .../storm/pacemaker/PacemakerClientHandler.java | 8 +- .../storm/pacemaker/PacemakerClientPool.java | 9 +- .../pacemaker/PacemakerConnectionException.java | 6 +- .../storm/pacemaker/codec/ThriftDecoder.java | 22 +- .../storm/pacemaker/codec/ThriftEncoder.java | 15 +- .../pacemaker/codec/ThriftNettyClientCodec.java | 16 +- .../jvm/org/apache/storm/policy/IWaitStrategy.java | 10 +- .../org/apache/storm/policy/WaitStrategyPark.java | 9 +- .../storm/policy/WaitStrategyProgressive.java | 42 +- .../storm/security/INimbusCredentialPlugin.java | 24 +- .../org/apache/storm/security/auth/AutoSSL.java | 17 +- .../storm/security/auth/ClientAuthUtils.java | 92 +- .../security/auth/DefaultPrincipalToLocal.java | 3 +- .../storm/security/auth/FixedGroupsMapping.java | 4 +- .../apache/storm/security/auth/IAuthorizer.java | 3 +- .../storm/security/auth/IAutoCredentials.java | 7 +- .../storm/security/auth/ICredentialsRenewer.java | 3 +- .../auth/IGroupMappingServiceProvider.java | 3 +- .../storm/security/auth/IPrincipalToLocal.java | 3 +- .../storm/security/auth/ITransportPlugin.java | 11 +- .../security/auth/KerberosPrincipalToLocal.java | 2 +- .../storm/security/auth/MultiThriftServer.java | 14 +- .../org/apache/storm/security/auth/ReqContext.java | 15 +- .../security/auth/ShellBasedGroupsMapping.java | 16 +- .../storm/security/auth/SimpleTransportPlugin.java | 23 +- .../apache/storm/security/auth/SubjectCompat.java | 13 +- .../storm/security/auth/TBackoffConnect.java | 13 +- .../apache/storm/security/auth/ThriftClient.java | 56 +- .../storm/security/auth/ThriftConnectionType.java | 35 +- .../apache/storm/security/auth/ThriftServer.java | 14 +- .../auth/X509CertOrKerberosPrincipalToLocal.java | 15 +- .../security/auth/X509CertPrincipalToLocal.java | 11 +- .../auth/authorizer/DRPCAuthorizerBase.java | 9 +- .../auth/authorizer/DRPCSimpleACLAuthorizer.java | 24 +- .../auth/authorizer/ImpersonationAuthorizer.java | 38 +- .../auth/authorizer/SimpleACLAuthorizer.java | 101 +- .../auth/authorizer/SimpleWhitelistAuthorizer.java | 3 +- .../authorizer/SupervisorSimpleACLAuthorizer.java | 26 +- .../auth/digest/DigestSaslTransportPlugin.java | 35 +- .../security/auth/digest/JassPasswordProvider.java | 17 +- .../storm/security/auth/kerberos/AutoTGT.java | 54 +- .../auth/kerberos/AutoTGTKrb5LoginModule.java | 4 +- .../auth/kerberos/ClientCallbackHandler.java | 35 +- .../auth/kerberos/KerberosSaslTransportPlugin.java | 128 +- .../auth/kerberos/ServerCallbackHandler.java | 33 +- .../auth/plain/PlainClientCallbackHandler.java | 3 +- .../auth/plain/PlainSaslTransportPlugin.java | 36 +- .../storm/security/auth/plain/SaslPlainServer.java | 18 +- .../storm/security/auth/sasl/PasswordProvider.java | 12 +- .../security/auth/sasl/SaslTransportPlugin.java | 31 +- .../auth/sasl/SimpleSaslServerCallbackHandler.java | 56 +- .../auth/tls/ReloadableTsslTransportFactory.java | 23 +- .../auth/tls/ReloadableX509KeyManager.java | 25 +- .../auth/tls/ReloadableX509TrustManager.java | 31 +- .../security/auth/tls/TlsTransportPlugin.java | 27 +- .../auth/workertoken/WorkerTokenAuthorizer.java | 30 +- .../WorkerTokenClientCallbackHandler.java | 17 +- .../auth/workertoken/WorkerTokenSigner.java | 15 +- .../serialization/BlowfishTupleSerializer.java | 23 +- .../storm/serialization/DefaultKryoFactory.java | 16 +- .../GzipBridgeThriftSerializationDelegate.java | 8 +- .../serialization/GzipSerializationDelegate.java | 9 +- .../GzipThriftSerializationDelegate.java | 9 +- .../apache/storm/serialization/IKryoDecorator.java | 2 + .../storm/serialization/ITupleSerializer.java | 1 - .../storm/serialization/KryoTupleDeserializer.java | 39 +- .../storm/serialization/KryoTupleSerializer.java | 15 +- .../serialization/SerializableSerializer.java | 28 +- .../storm/serialization/SerializationFactory.java | 41 +- .../storm/serialization/SerializationRegister.java | 6 +- .../TupleDeserializationException.java | 3 +- .../ZstdBridgeThriftSerializationDelegate.java | 9 +- .../ZstdThriftSerializationDelegate.java | 15 +- .../serialization/types/ArrayListSerializer.java | 2 - .../serialization/types/HashMapSerializer.java | 5 +- .../serialization/types/HashSetSerializer.java | 2 - .../types/ListDelegateSerializer.java | 5 +- .../org/apache/storm/spout/CheckPointState.java | 29 +- .../org/apache/storm/spout/CheckpointSpout.java | 21 +- .../src/jvm/org/apache/storm/spout/ISpout.java | 75 +- .../apache/storm/spout/ISpoutOutputCollector.java | 3 +- .../src/jvm/org/apache/storm/spout/RawScheme.java | 2 +- .../src/jvm/org/apache/storm/spout/Scheme.java | 1 - .../src/jvm/org/apache/storm/spout/ShellSpout.java | 55 +- .../apache/storm/spout/SpoutOutputCollector.java | 75 +- .../storm/state/BaseBinaryStateIterator.java | 8 +- .../org/apache/storm/state/BaseStateIterator.java | 7 +- .../apache/storm/state/DefaultStateEncoder.java | 11 +- .../apache/storm/state/DefaultStateSerializer.java | 31 +- .../src/jvm/org/apache/storm/state/State.java | 15 +- .../jvm/org/apache/storm/state/StateFactory.java | 9 +- .../jvm/org/apache/storm/state/StateProvider.java | 3 +- .../storm/state/SynchronizeOutputCollector.java | 1 - .../org/apache/storm/stats/BoltExecutorStats.java | 31 +- .../org/apache/storm/stats/ClientStatsUtil.java | 12 +- .../org/apache/storm/stats/SpoutExecutorStats.java | 2 +- .../jvm/org/apache/storm/streams/GroupingInfo.java | 15 +- .../src/jvm/org/apache/storm/streams/Node.java | 9 +- .../jvm/org/apache/storm/streams/PairStream.java | 184 ++- .../org/apache/storm/streams/PartitionNode.java | 3 +- .../org/apache/storm/streams/ProcessorBolt.java | 4 +- .../storm/streams/ProcessorBoltDelegate.java | 40 +- .../org/apache/storm/streams/ProcessorNode.java | 3 +- .../org/apache/storm/streams/RefCountedTuple.java | 3 +- .../storm/streams/StatefulProcessorBolt.java | 6 +- .../src/jvm/org/apache/storm/streams/Stream.java | 182 ++- .../org/apache/storm/streams/StreamBuilder.java | 102 +- .../jvm/org/apache/storm/streams/StreamState.java | 3 +- .../storm/streams/WindowedProcessorBolt.java | 3 +- .../storm/streams/operations/BiFunction.java | 2 +- .../streams/operations/CombinerAggregator.java | 9 +- .../streams/operations/PairFlatMapFunction.java | 3 +- .../storm/streams/operations/PairValueJoiner.java | 3 +- .../apache/storm/streams/operations/Reducer.java | 3 +- .../storm/streams/operations/StateUpdater.java | 6 +- .../operations/mappers/PairValueMapper.java | 3 +- .../operations/mappers/TupleValueMappers.java | 176 +-- .../streams/operations/mappers/ValuesMapper.java | 3 +- .../storm/streams/processors/BaseProcessor.java | 18 +- .../storm/streams/processors/BatchProcessor.java | 3 +- .../processors/ChainedProcessorContext.java | 3 +- .../streams/processors/CoGroupByKeyProcessor.java | 8 +- .../processors/EmittingProcessorContext.java | 9 +- .../processors/ForwardingProcessorContext.java | 3 +- .../storm/streams/processors/JoinProcessor.java | 9 +- .../apache/storm/streams/processors/Processor.java | 6 +- .../storm/streams/processors/ProcessorContext.java | 3 +- .../org/apache/storm/streams/tuple/Tuple10.java | 3 +- .../jvm/org/apache/storm/streams/tuple/Tuple6.java | 3 +- .../jvm/org/apache/storm/streams/tuple/Tuple7.java | 3 +- .../jvm/org/apache/storm/streams/tuple/Tuple8.java | 6 +- .../jvm/org/apache/storm/streams/tuple/Tuple9.java | 3 +- .../apache/storm/streams/windowing/BaseWindow.java | 6 +- .../storm/streams/windowing/SlidingWindows.java | 33 +- .../storm/streams/windowing/TumblingWindows.java | 27 +- .../org/apache/storm/streams/windowing/Window.java | 12 +- .../apache/storm/task/GeneralTopologyContext.java | 15 +- .../src/jvm/org/apache/storm/task/IBolt.java | 63 +- .../jvm/org/apache/storm/task/IMetricsContext.java | 6 +- .../jvm/org/apache/storm/task/OutputCollector.java | 99 +- .../src/jvm/org/apache/storm/task/ShellBolt.java | 77 +- .../jvm/org/apache/storm/task/TopologyContext.java | 68 +- .../apache/storm/task/WorkerTopologyContext.java | 78 +- .../org/apache/storm/task/WorkerUserContext.java | 36 +- .../testing/AlternateRackDNSToSwitchMapping.java | 5 +- .../jvm/org/apache/storm/testing/BoltTracker.java | 1 - .../org/apache/storm/testing/CompletableSpout.java | 5 +- .../jvm/org/apache/storm/testing/FeederSpout.java | 4 +- .../org/apache/storm/testing/FixedTupleSpout.java | 3 +- .../storm/testing/ForwardingMetricsConsumer.java | 6 +- .../org/apache/storm/testing/MkClusterParam.java | 12 +- .../org/apache/storm/testing/MockedSources.java | 6 +- .../jvm/org/apache/storm/testing/NGrouping.java | 3 +- .../apache/storm/testing/NonRichBoltTracker.java | 4 +- .../org/apache/storm/testing/PrepareBatchBolt.java | 2 - .../storm/testing/PythonShellMetricsBolt.java | 3 +- .../storm/testing/PythonShellMetricsSpout.java | 3 +- .../storm/testing/SingleUserSimpleTransport.java | 1 - .../jvm/org/apache/storm/testing/SpoutTracker.java | 8 +- .../storm/testing/TestAggregatesCounter.java | 4 +- .../jvm/org/apache/storm/testing/TestConfBolt.java | 1 - .../apache/storm/testing/TestEventLogSpout.java | 3 +- .../storm/testing/TestEventOrderCheckBolt.java | 6 +- .../org/apache/storm/testing/TestGlobalCount.java | 4 +- .../org/apache/storm/testing/TestPlannerBolt.java | 4 +- .../org/apache/storm/testing/TestPlannerSpout.java | 5 +- .../org/apache/storm/testing/TestWordCounter.java | 1 - .../org/apache/storm/testing/TestWordSpout.java | 6 +- .../src/jvm/org/apache/storm/testing/TmpPath.java | 2 +- .../org/apache/storm/testing/TupleCaptureBolt.java | 29 +- .../storm/topology/BaseConfigurationDeclarer.java | 8 +- .../storm/topology/BaseStatefulBoltExecutor.java | 27 +- .../apache/storm/topology/BasicBoltExecutor.java | 4 +- .../storm/topology/BasicOutputCollector.java | 7 +- .../storm/topology/CheckpointTupleForwarder.java | 14 +- .../topology/ComponentConfigurationDeclarer.java | 4 +- .../storm/topology/ConfigurableTopology.java | 11 +- .../jvm/org/apache/storm/topology/IComponent.java | 12 +- .../jvm/org/apache/storm/topology/IRichBolt.java | 3 +- .../jvm/org/apache/storm/topology/IRichSpout.java | 3 +- .../org/apache/storm/topology/IRichStateSpout.java | 1 - .../org/apache/storm/topology/IStatefulBolt.java | 9 +- .../apache/storm/topology/IStatefulComponent.java | 18 +- .../storm/topology/IStatefulWindowedBolt.java | 7 +- .../org/apache/storm/topology/IWindowedBolt.java | 9 +- .../org/apache/storm/topology/InputDeclarer.java | 31 +- .../storm/topology/OutputFieldsDeclarer.java | 1 - .../apache/storm/topology/OutputFieldsGetter.java | 1 - .../topology/PersistentWindowedBoltExecutor.java | 60 +- .../apache/storm/topology/ResourceDeclarer.java | 6 +- .../storm/topology/StatefulBoltExecutor.java | 24 +- .../topology/StatefulWindowedBoltExecutor.java | 52 +- .../org/apache/storm/topology/TopologyBuilder.java | 333 +++-- .../storm/topology/WindowedBoltExecutor.java | 114 +- .../storm/topology/base/BaseStatefulBolt.java | 3 +- .../topology/base/BaseStatefulWindowedBolt.java | 15 +- .../topology/base/BaseTickTupleAwareRichBolt.java | 6 +- .../storm/topology/base/BaseWindowedBolt.java | 36 +- .../storm/transactional/TransactionAttempt.java | 1 - .../apache/storm/trident/JoinOutFieldsMode.java | 9 +- .../src/jvm/org/apache/storm/trident/Stream.java | 263 ++-- .../jvm/org/apache/storm/trident/TridentState.java | 1 - .../org/apache/storm/trident/TridentTopology.java | 222 +-- .../storm/trident/drpc/ReturnResultsReducer.java | 3 +- .../trident/fluent/ChainedAggregatorDeclarer.java | 49 +- .../fluent/ChainedFullAggregatorDeclarer.java | 9 +- .../fluent/ChainedPartitionAggregatorDeclarer.java | 15 +- .../trident/fluent/GlobalAggregationScheme.java | 1 - .../apache/storm/trident/fluent/GroupedStream.java | 70 +- .../storm/trident/fluent/IAggregatableStream.java | 3 +- .../jvm/org/apache/storm/trident/graph/Group.java | 39 +- .../apache/storm/trident/operation/Assembly.java | 4 +- .../storm/trident/operation/BaseMultiReducer.java | 1 - .../storm/trident/operation/BaseOperation.java | 3 +- .../apache/storm/trident/operation/Consumer.java | 3 +- .../trident/operation/DefaultResourceDeclarer.java | 13 +- .../org/apache/storm/trident/operation/Filter.java | 9 +- .../apache/storm/trident/operation/Function.java | 42 +- .../trident/operation/GroupedMultiReducer.java | 4 +- .../storm/trident/operation/ITridentResource.java | 5 +- .../storm/trident/operation/MultiReducer.java | 1 - .../apache/storm/trident/operation/Operation.java | 12 +- .../operation/OperationAwareFlatMapFunction.java | 3 +- .../operation/OperationAwareMapFunction.java | 3 +- .../storm/trident/operation/TridentCollector.java | 10 +- .../operation/TridentMultiReducerContext.java | 1 - .../trident/operation/TridentOperationContext.java | 5 +- .../operation/builtin/ComparisonAggregator.java | 14 +- .../storm/trident/operation/builtin/Count.java | 1 - .../storm/trident/operation/builtin/Debug.java | 3 +- .../storm/trident/operation/builtin/Equals.java | 1 - .../trident/operation/builtin/FilterNull.java | 3 +- .../storm/trident/operation/builtin/FirstN.java | 5 +- .../storm/trident/operation/builtin/MapGet.java | 1 - .../storm/trident/operation/builtin/Max.java | 3 +- .../storm/trident/operation/builtin/Min.java | 3 +- .../operation/builtin/MinWithComparator.java | 3 +- .../storm/trident/operation/builtin/Negate.java | 12 +- .../storm/trident/operation/builtin/Sum.java | 1 - .../operation/builtin/TupleCollectionGet.java | 3 +- .../operation/impl/ChainedAggregatorImpl.java | 5 +- .../trident/operation/impl/ChainedResult.java | 3 +- .../operation/impl/CombinerAggStateUpdater.java | 7 +- .../trident/operation/impl/GroupedAggregator.java | 2 +- .../impl/GroupedMultiReducerExecutor.java | 10 +- .../operation/impl/IdentityMultiReducer.java | 1 - .../trident/operation/impl/JoinerMultiReducer.java | 19 +- .../PreservingFieldsOrderJoinerMultiReducer.java | 28 +- .../operation/impl/ReducerAggStateUpdater.java | 4 +- .../operation/impl/SingleEmitAggregator.java | 6 +- .../storm/trident/partition/GlobalGrouping.java | 3 +- .../storm/trident/partition/IdentityGrouping.java | 10 +- .../storm/trident/partition/IndexHashGrouping.java | 3 +- .../storm/trident/planner/BridgeReceiver.java | 1 - .../storm/trident/planner/PartitionNode.java | 3 +- .../storm/trident/planner/ProcessorNode.java | 6 +- .../apache/storm/trident/planner/SpoutNode.java | 6 +- .../storm/trident/planner/SubtopologyBolt.java | 42 +- .../storm/trident/planner/TupleReceiver.java | 3 +- .../planner/processor/AggregateProcessor.java | 10 +- .../trident/planner/processor/AppendCollector.java | 4 +- .../trident/planner/processor/EachProcessor.java | 5 +- .../trident/planner/processor/FreshCollector.java | 1 - .../trident/planner/processor/MapProcessor.java | 3 +- .../planner/processor/MultiReducerProcessor.java | 10 +- .../processor/PartitionPersistProcessor.java | 7 +- .../planner/processor/ProjectedProcessor.java | 7 +- .../planner/processor/StateQueryProcessor.java | 10 +- .../trident/planner/processor/TridentContext.java | 3 +- .../storm/trident/spout/BatchSpoutExecutor.java | 9 +- .../spout/IOpaquePartitionedTridentSpout.java | 50 +- .../trident/spout/IPartitionedTridentSpout.java | 47 +- .../apache/storm/trident/spout/ITridentSpout.java | 51 +- .../OpaquePartitionedTridentSpoutExecutor.java | 55 +- .../spout/PartitionedTridentSpoutExecutor.java | 38 +- .../trident/spout/RichSpoutBatchExecutor.java | 14 +- .../trident/spout/RichSpoutBatchIdSerializer.java | 1 - .../trident/spout/RichSpoutBatchTriggerer.java | 10 +- .../trident/spout/TridentSpoutCoordinator.java | 5 +- .../storm/trident/spout/TridentSpoutExecutor.java | 4 +- .../storm/trident/state/BaseQueryFunction.java | 1 - .../storm/trident/state/BaseStateUpdater.java | 1 - .../state/JSONNonTransactionalSerializer.java | 1 - .../apache/storm/trident/state/OpaqueValue.java | 6 +- .../apache/storm/trident/state/ReadOnlyState.java | 6 +- .../org/apache/storm/trident/state/Serializer.java | 1 - .../jvm/org/apache/storm/trident/state/State.java | 15 +- .../apache/storm/trident/state/StateFactory.java | 3 +- .../org/apache/storm/trident/state/StateSpec.java | 1 - .../apache/storm/trident/state/StateUpdater.java | 4 +- .../trident/state/map/CachedBatchReadsMap.java | 2 - .../apache/storm/trident/state/map/CachedMap.java | 3 +- .../storm/trident/state/map/IBackingMap.java | 1 - .../state/map/MapCombinerAggStateUpdater.java | 10 +- .../state/map/MapReducerAggStateUpdater.java | 7 +- .../trident/state/map/MicroBatchIBackingMap.java | 1 - .../trident/state/map/NonTransactionalMap.java | 1 - .../apache/storm/trident/state/map/OpaqueMap.java | 1 - .../storm/trident/state/map/SnapshottableMap.java | 1 - .../storm/trident/state/map/TransactionalMap.java | 1 - .../trident/state/snapshot/Snapshottable.java | 1 - .../storm/trident/testing/CountAsAggregator.java | 1 - .../storm/trident/testing/FeederBatchSpout.java | 23 +- .../trident/testing/FeederCommitterBatchSpout.java | 8 +- .../storm/trident/testing/FixedBatchSpout.java | 1 - .../storm/trident/testing/LRUMemoryMapState.java | 9 +- .../storm/trident/testing/MemoryMapState.java | 12 +- .../apache/storm/trident/topology/BatchInfo.java | 1 - .../trident/topology/MasterBatchCoordinator.java | 30 +- .../storm/trident/topology/TransactionAttempt.java | 2 - .../trident/topology/TridentBoltExecutor.java | 35 +- .../trident/topology/TridentTopologyBuilder.java | 102 +- .../topology/state/RotatingTransactionalState.java | 3 +- .../topology/state/TestTransactionalState.java | 2 +- .../trident/topology/state/TransactionalState.java | 38 +- .../org/apache/storm/trident/tuple/ComboList.java | 6 +- .../storm/trident/tuple/TridentTupleView.java | 18 +- .../apache/storm/trident/tuple/ValuePointer.java | 3 +- .../org/apache/storm/trident/util/IndexedEdge.java | 1 - .../apache/storm/trident/util/TridentUtils.java | 1 - .../windowing/AbstractTridentWindowManager.java | 20 +- .../trident/windowing/ITridentWindowManager.java | 3 +- .../windowing/InMemoryTridentWindowManager.java | 3 +- .../trident/windowing/InMemoryWindowsStore.java | 4 +- .../windowing/InMemoryWindowsStoreFactory.java | 6 +- .../windowing/StoreBasedTridentWindowManager.java | 42 +- .../storm/trident/windowing/TridentBatchTuple.java | 3 +- .../trident/windowing/WindowKryoSerializer.java | 6 +- .../trident/windowing/WindowTridentProcessor.java | 50 +- .../trident/windowing/WindowsStateFactory.java | 3 +- .../trident/windowing/WindowsStateUpdater.java | 23 +- .../storm/trident/windowing/WindowsStore.java | 3 +- .../trident/windowing/WindowsStoreFactory.java | 3 +- .../trident/windowing/config/BaseWindowConfig.java | 3 +- .../windowing/config/SlidingDurationWindow.java | 3 +- .../strategy/SlidingCountWindowStrategy.java | 6 +- .../strategy/SlidingDurationWindowStrategy.java | 6 +- .../strategy/TumblingCountWindowStrategy.java | 6 +- .../strategy/TumblingDurationWindowStrategy.java | 6 +- .../trident/windowing/strategy/WindowStrategy.java | 3 +- .../jvm/org/apache/storm/tuple/AddressedTuple.java | 8 +- .../jvm/org/apache/storm/tuple/DetachedTuple.java | 21 +- .../src/jvm/org/apache/storm/tuple/Fields.java | 9 +- .../src/jvm/org/apache/storm/tuple/ITuple.java | 30 +- .../src/jvm/org/apache/storm/tuple/Tuple.java | 12 +- .../src/jvm/org/apache/storm/tuple/TupleImpl.java | 11 +- .../jvm/org/apache/storm/utils/BatchHelper.java | 2 +- .../apache/storm/utils/BufferFileInputStream.java | 1 - .../jvm/org/apache/storm/utils/ConfigUtils.java | 107 +- .../jvm/org/apache/storm/utils/CuratorUtils.java | 52 +- .../src/jvm/org/apache/storm/utils/DRPCClient.java | 26 +- .../apache/storm/utils/DefaultShellLogHandler.java | 5 +- .../storm/utils/DisallowedStrategyException.java | 9 +- .../storm/utils/ExtendedThreadPoolExecutor.java | 15 +- .../org/apache/storm/utils/HadoopLoginUtil.java | 17 +- .../src/jvm/org/apache/storm/utils/IPredicate.java | 3 +- .../jvm/org/apache/storm/utils/IVersionInfo.java | 6 + .../org/apache/storm/utils/InprocMessaging.java | 5 +- .../src/jvm/org/apache/storm/utils/JCQueue.java | 178 ++- .../jvm/org/apache/storm/utils/JCQueueMetrics.java | 39 +- .../org/apache/storm/utils/KeyStreamRandom.java | 24 +- .../src/jvm/org/apache/storm/utils/LocalState.java | 21 +- .../jvm/org/apache/storm/utils/NimbusClient.java | 90 +- .../storm/utils/NimbusLeaderNotFoundException.java | 3 +- .../jvm/org/apache/storm/utils/ObjectReader.java | 1 + .../org/apache/storm/utils/ReflectionUtils.java | 35 +- .../apache/storm/utils/RegisteredGlobalState.java | 6 +- .../jvm/org/apache/storm/utils/RotatingMap.java | 11 +- .../jvm/org/apache/storm/utils/SecurityUtils.java | 3 +- .../apache/storm/utils/ShellBoltMessageQueue.java | 13 +- .../org/apache/storm/utils/ShellCommandRunner.java | 14 +- .../apache/storm/utils/ShellCommandRunnerImpl.java | 5 +- .../org/apache/storm/utils/ShellLogHandler.java | 3 +- .../jvm/org/apache/storm/utils/ShellProcess.java | 26 +- .../src/jvm/org/apache/storm/utils/ShellUtils.java | 77 +- .../jvm/org/apache/storm/utils/SimpleVersion.java | 4 +- .../utils/StormBoundedExponentialBackoffRetry.java | 24 +- .../org/apache/storm/utils/SupervisorClient.java | 39 +- .../apache/storm/utils/ThriftTopologyUtils.java | 3 +- .../src/jvm/org/apache/storm/utils/Time.java | 33 +- .../jvm/org/apache/storm/utils/TimeCacheMap.java | 12 +- .../org/apache/storm/utils/TransferDrainer.java | 6 +- .../src/jvm/org/apache/storm/utils/TupleUtils.java | 7 +- .../src/jvm/org/apache/storm/utils/Utils.java | 397 ++++-- .../jvm/org/apache/storm/utils/VersionInfo.java | 40 +- .../jvm/org/apache/storm/utils/VersionedStore.java | 4 +- .../apache/storm/utils/WindowedTimeThrottler.java | 2 +- .../jvm/org/apache/storm/utils/WritableUtils.java | 15 +- .../org/apache/storm/utils/ZookeeperAuthInfo.java | 1 - .../apache/storm/validation/ConfigValidation.java | 343 +++-- .../validation/ConfigValidationAnnotations.java | 37 +- .../storm/validation/ConfigValidationUtils.java | 19 +- .../jvm/org/apache/storm/validation/NotConf.java | 3 +- .../jvm/org/apache/storm/validation/Validated.java | 2 +- .../apache/storm/windowing/CountTriggerPolicy.java | 6 +- .../storm/windowing/DefaultEvictionContext.java | 3 +- .../src/jvm/org/apache/storm/windowing/Event.java | 6 +- .../apache/storm/windowing/EvictionContext.java | 7 +- .../org/apache/storm/windowing/EvictionPolicy.java | 27 +- .../storm/windowing/StatefulWindowManager.java | 15 +- .../apache/storm/windowing/TimeEvictionPolicy.java | 15 +- .../apache/storm/windowing/TimeTriggerPolicy.java | 18 +- .../org/apache/storm/windowing/TriggerHandler.java | 3 +- .../org/apache/storm/windowing/TriggerPolicy.java | 8 +- .../apache/storm/windowing/TupleWindowImpl.java | 3 +- .../storm/windowing/WaterMarkEventGenerator.java | 24 +- .../windowing/WatermarkCountEvictionPolicy.java | 14 +- .../windowing/WatermarkCountTriggerPolicy.java | 9 +- .../windowing/WatermarkTimeEvictionPolicy.java | 20 +- .../windowing/WatermarkTimeTriggerPolicy.java | 18 +- .../src/jvm/org/apache/storm/windowing/Window.java | 43 +- .../storm/windowing/WindowLifecycleListener.java | 12 +- .../org/apache/storm/windowing/WindowManager.java | 34 +- .../persistence/SimpleWindowPartitionCache.java | 12 +- .../persistence/WindowPartitionCache.java | 3 +- .../storm/windowing/persistence/WindowState.java | 77 +- .../apache/storm/zookeeper/ClientZookeeper.java | 35 +- .../test/jvm/org/apache/storm/ConstantsTest.java | 14 +- .../storm/PaceMakerStateStorageFactoryTest.java | 32 +- .../jvm/org/apache/storm/TestConfigValidate.java | 271 ++-- .../jvm/org/apache/storm/TestStormSubmitter.java | 11 +- .../test/jvm/org/apache/storm/TestStormTimer.java | 96 +- .../assignments/LocalAssignmentsBackendTest.java | 16 +- .../storm/blobstore/ClientBlobStoreTest.java | 9 +- .../jvm/org/apache/storm/bolt/TestJoinBolt.java | 155 +- .../org/apache/storm/cluster/DaemonTypeTest.java | 12 +- .../storm/cluster/StormClusterStateImplTest.java | 6 +- .../daemon/metrics/ClientMetricsUtilsTest.java | 6 +- .../daemon/worker/BackPressureTrackerTest.java | 13 +- .../storm/daemon/worker/LogConfigManagerTest.java | 69 +- .../daemon/worker/TestUtilsForWorkerState.java | 28 +- .../storm/daemon/worker/WorkerStateTest.java | 65 +- .../org/apache/storm/daemon/worker/WorkerTest.java | 6 +- .../dependency/DependencyPropertiesParserTest.java | 15 +- .../storm/dependency/DependencyUploaderTest.java | 85 +- .../apache/storm/executor/ChildEwmaStatsTest.java | 12 +- .../storm/executor/EwmaFeedbackRecordTest.java | 72 +- .../executor/ExecutorTransferControlLaneTest.java | 43 +- .../ExecutorTransferMultiThreadingTest.java | 71 +- .../apache/storm/executor/SpoutExecutorTest.java | 44 +- .../storm/executor/error/ReportErrorTest.java | 21 +- .../grouping/JitterAwareStreamGroupingTest.java | 52 +- .../grouping/LoadAwareShuffleGroupingTest.java | 99 +- .../apache/storm/grouping/ShuffleGroupingTest.java | 16 +- .../BalancedTargetSelectorTest.java | 21 +- .../partialKeyGrouping/PartialKeyGroupingTest.java | 17 +- .../RandomTwoTaskAssignmentCreatorTest.java | 35 +- .../DeserializingConnectionCallbackTest.java | 176 ++- .../storm/messaging/netty/MessageDecoderTest.java | 22 +- .../apache/storm/messaging/netty/ServerTest.java | 33 +- .../netty/StormClientPipelineFactoryTest.java | 8 +- .../messaging/netty/StormServerHandlerTest.java | 20 +- .../storm/metric/FileBasedEventLoggerTest.java | 17 +- .../metric/filter/FilterByMetricNameTest.java | 17 +- .../storm/metric/internal/CountStatTest.java | 8 +- .../storm/metric/internal/LatencyStatTest.java | 22 +- .../storm/metric/internal/RateTrackerTest.java | 18 +- .../storm/metric/util/DataPointExpanderTest.java | 27 +- .../org/apache/storm/metrics2/EwmaGaugeTest.java | 28 +- .../storm/metrics2/RollingAverageGaugeTest.java | 4 +- .../org/apache/storm/metrics2/TaskMetricsTest.java | 77 +- .../org/apache/storm/nimbus/NimbusInfoTest.java | 4 +- .../storm/pacemaker/codec/ThriftDecoderTest.java | 64 +- .../storm/security/auth/AuthUtilsTestMock.java | 30 +- .../apache/storm/security/auth/AutoSSLTest.java | 17 +- .../storm/security/auth/ClientAuthUtilsTest.java | 52 +- .../storm/security/auth/MultiThriftServerTest.java | 20 +- .../apache/storm/security/auth/ReqContextTest.java | 7 +- .../security/auth/SaslTransportPluginTest.java | 6 +- .../security/auth/ShellBasedGroupsMappingTest.java | 25 +- .../storm/security/auth/SubjectCompatTest.java | 20 +- .../security/auth/TestingITransportPlugin.java | 3 +- .../storm/security/auth/ThriftClientTest.java | 20 +- .../security/auth/TlsTransportPluginTest.java | 30 +- .../auth/X509CertPrincipalToLocalTest.java | 21 +- .../authorizer/DRPCSimpleACLAuthorizerTest.java | 87 +- .../auth/authorizer/SimpleACLAuthorizerTest.java | 184 ++- .../SupervisorSimpleACLAuthorizerTest.java | 14 +- .../auth/kerberos/AutoLoginModuleTest.java | 35 +- .../serialization/BlowfishTupleSerializerTest.java | 47 +- .../GzipBridgeThriftSerializationDelegateTest.java | 5 +- .../KryoTupleSerializerDeserializerTest.java | 127 +- .../SerializableSerializerFilterTest.java | 149 +- .../serialization/SerializationFactoryTest.java | 18 +- .../ThriftBridgeSerializationDelegateTest.java | 5 +- .../ZstdBridgeThriftSerializationDelegateTest.java | 15 +- .../ZstdThriftSerializationDelegateTest.java | 6 +- .../apache/storm/spout/CheckpointSpoutTest.java | 57 +- .../storm/state/BaseBinaryStateIteratorTest.java | 22 +- .../storm/state/DefaultStateSerializerTest.java | 48 +- .../storm/state/InMemoryKeyValueStateTest.java | 36 +- .../apache/storm/streams/ProcessorBoltTest.java | 39 +- .../storm/streams/StatefulProcessorBoltTest.java | 16 +- .../apache/storm/streams/StreamBuilderTest.java | 92 +- .../storm/streams/WindowedProcessorBoltTest.java | 12 +- .../processors/CoGroupByKeyProcessorTest.java | 61 +- .../streams/processors/JoinProcessorTest.java | 24 +- .../org/apache/storm/testing/IntegrationTest.java | 11 +- .../org/apache/storm/testing/PerformanceTest.java | 8 +- .../PersistentWindowedBoltExecutorTest.java | 72 +- .../topology/SimpleWindowPartitionCacheTest.java | 123 +- .../storm/topology/StatefulBoltExecutorTest.java | 108 +- .../topology/StatefulWindowedBoltExecutorTest.java | 28 +- .../apache/storm/topology/TopologyBuilderTest.java | 61 +- .../storm/topology/WindowedBoltExecutorTest.java | 102 +- .../apache/storm/trident/TestTridentTopology.java | 14 +- .../apache/storm/trident/TridentWindowingTest.java | 30 +- .../org/apache/storm/tuple/DetachedTupleTest.java | 42 +- .../jvm/org/apache/storm/tuple/FieldsTest.java | 18 +- .../jvm/org/apache/storm/tuple/MessageIdTest.java | 17 +- .../org/apache/storm/utils/ConfigUtilsTest.java | 58 +- .../org/apache/storm/utils/CuratorUtilsTest.java | 86 +- .../storm/utils/DefaultShellLogHandlerTest.java | 10 +- .../storm/utils/JCQueueBackpressureTest.java | 20 +- .../jvm/org/apache/storm/utils/JCQueueTest.java | 74 +- .../org/apache/storm/utils/PredicateMatcher.java | 4 +- .../apache/storm/utils/ReflectionUtilsTest.java | 25 +- .../org/apache/storm/utils/SecurityUtilsTest.java | 12 +- .../storm/utils/ShellBoltMessageQueueTest.java | 11 +- .../jvm/org/apache/storm/utils/ShellUtilsTest.java | 9 +- .../org/apache/storm/utils/SimpleVersionTest.java | 4 +- .../StormBoundedExponentialBackoffRetryTest.java | 40 +- .../storm/utils/ThriftTopologyUtilsTest.java | 42 +- .../test/jvm/org/apache/storm/utils/TimeTest.java | 6 +- .../test/jvm/org/apache/storm/utils/UtilsTest.java | 218 +-- .../windowing/WaterMarkEventGeneratorTest.java | 12 +- .../apache/storm/windowing/WindowManagerTest.java | 125 +- .../windowing/persistence/WindowStateTest.java | 18 +- 728 files changed, 12302 insertions(+), 7784 deletions(-)
