This is an automated email from the ASF dual-hosted git repository.
rzo1 pushed a change to branch
dependabot/maven/org.apache.hadoop-hadoop-common-3.2.3
in repository https://gitbox.apache.org/repos/asf/storm.git
from 7c4dd9019 Bump hadoop-common from 2.10.1 to 3.2.3
add 9be54dce2 [STORM-3855] Remove python2 support and move to python3.
(#3475)
add 33918ad0d STORM-3805 Changing error to warn for retry update
operations (#3422)
add a8fb509f7 [STORM-3832] Moving unit tests from junit4 to junit5 (#3479)
add 6807f1d41 MINOR: add blobstore documentation for workerRestart (#3485)
add 8de7676f7 STORM-3872 Excluding unused pom dependencies (#3487)
add aa4772980 STORM-3875 remove topology gc opts from ThroughputVsLatency
to allow running on JDK11 (#3486)
add e694f5959 STORM-3873: Remove junit4 dependency (#3488)
add 5e110961a [STORM-3883] Update Kryo to version 4.0.2 (#3502)
add 272117273 Adding IgnoreUnrecognizedVMOptions to make worker start with
jdk-11 (#3503)
add eee796489 [STORM-3889] Bump snakeyaml from 1.26 to 1.32 (#3507)
add 6f184d326 [STORM-3887] Add AWS Kafka command processor
add 101ff47f4 [STORM-3887] Add license for init.sh
add f699ba5ad Merge pull request #3505 from bipinprasad/storm-3887
add 05037e2cf [hotfix] fix typo
add bf29d1cc9 Merge pull request #3508 from wuyouwuyoulian/typofix
add bce2814d7 [STORM-3890] Insert java class name and parameters.
add 3d6a7b782 Merge pull request #3512 from bipinprasad/storm-3890
add 7a0dda662 [STORM-3891] Use commons-cli defined in parent pom, change
python to python3 (#3513)
add e5a586082 Bump testng from 6.8.5 to 7.7.0 in /examples/storm-starter
(#3515)
add e6f399872 Bump testng from 6.8.5 to 7.7.0 in /integration-test (#3517)
add 7ac7b12aa Storm-Pulsar bolt and spout (#3440)
add 67472cf37 STORM-3897 - Replace Travis with GitHub Actions (#3520)
add 9f33ec4ab STORM-3898 - Add Integration Test Github Action (#3522)
add 4fb1feb94 STORM-3894 - SnakeYAML 2.0
add a6a2f0ac4 Merge pull request #3523 from rzo1/STORM-3894
add 9de339620 STORM-3899 - Migrate dev-tools travis scripts to "gitact"
after github actions are fully functional
add 70a2f63c4 Merge pull request #3524 from rzo1/STORM-3899
add 8e9dddb40 [STORM-3902] Print summary of differences between expected
and actual DEPENDENCY-LICENSES files. (#3527)
add b2bba828e [STORM-3903] Bump commons-fileupload from 1.3.3 to 1.5
(#3529)
add 6a6ed6cf1 [STORM-3904] Bump spring-core from 5.3.20 to 5.3.26 in
/examples/storm-jms-examples (#3528)
add e92c7cd35 [STORM-3906] Remove
org.mockito.internal.util.reflection.FieldSetter and upgrade mockito to 3.11.2
(#3531)
add e4d19dc7f [STORM-3905] Replace anonymous class with lambda in
storm-core commands (#3530)
add 8e1771808 [STORM-3907] Update mockito to version 4.11.0 and change
code to match. (#3532)
add 4579d8d04 [STORM-3908] Increase heap memory for MAVEN_OPTS used in
github actions
add 1724cd1f1 Merge pull request #3533 from bipinprasad/storm-3908
add 0fad75644 [STORM-3909] Use python3 in metrics test
add 339249830 Merge pull request #3534 from bipinprasad/storm-3909
add c8f1c2293 [STORM-3912] Reference new clojar for carbonite version 1.6.0
add d6f545d6b [STORM-3912] Update licenses.
add 702c5a1a7 Merge pull request #3537 from bipinprasad/storm-3912
add d7b4c084a [STORM-3913] Update rocksdb to version 8.1.1 that has Mac
OSX JNI lib (#3539)
add 21ee5d945 Fix infinite loop when no files are left to remove (#3541)
add 414f15551 Remove explicit worker heap size in ThroughputVsLatency
add a8aaf9f5e Merge pull request #3542 from jmartell7/patch-2
add 185724d47 STORM-3920 Update security doc
add 88735c7a9 Merge pull request #3543 from snikhil5/STORM-3920
add 50dbc2e89 [STORM-3910] Enahnced logging for rocksdb metrics store.
(#3535)
add a9f685fa7 [STORM-3911] fetch net.minidev:json-smart:2.3 artifact from
maven repo before conjars.org repo is referenced (#3536)
add 9a1c03660 [STORM-3921] Bump spring-core from 5.3.26 to 5.3.27 in
/examples/storm-jms-examples (#3538)
add ce3b2724b [STORM-3922] Acker scheduling changes. (#3544)
add 0fc921dc4 [STORM-3923] Increase MAVEN_OPTS max memory setting to 2gb
(#3545)
add 6a1049800 [STORM-3916] Add Round Robin Scheduling strategy with
optional node limit (#3540)
add 5a48fbecb [STORM-3926] Require python3 for bin/storm (#3548)
add 1636bb318 [STORM-3929] Update documentation to refer to python3 (#3551)
add 707e817b2 [STORM-3928] Use python3 in flux test, examples and wrappers
(#3550)
add cc33e5e4b [STORM-3927] Change python to python3 in examples (#3549)
add 49e3d1c8d [STORM-3930] Change the source code control URI from https
to ssh, and update the uri from gitbox to github (#3552)
add e88a2743f [maven-release-plugin] prepare release v2.5.0
add 4606dc646 [maven-release-plugin] prepare for next development iteration
add 44b8b32ee [maven-release-plugin] rollback the release of v2.5.0
add 4f6c31f44 Use latest version of maven-release-plugin, refer to
https://issues.apache.org/jira/projects/INFRA/issues/INFRA-24780
add 19f30fa71 Reset version in storm-dist/**/pom.xml
add d1726f0df [maven-release-plugin] prepare release v2.5.0
add 2d0543a67 [maven-release-plugin] prepare for next development iteration
add bd9a7ad80 [maven-release-plugin] rollback the release of v2.5.0
add f3a4d2044 Update pom.xml scm.connection and scm.developerConnection
add 2a3bf5152 Add Nexus Apache staging/snapshot repositories to
distributionManagement tag
add b109d3eb6 [maven-release-plugin] prepare release v2.5.0
add 4412ac96b [maven-release-plugin] prepare for next development iteration
add 297e7b4ed [maven-release-plugin] rollback the release of v2.5.0
add 9b43c182e Upgrade parent pom version to 30. Remove
distributionManagement tag already included in parent pom.
add a079e1d3d Add license to .gitattributes to avoid rat error.
add f8c549c4b [maven-release-plugin] prepare release v2.5.0
add 87540c1f6 [maven-release-plugin] prepare for next development iteration
add 885598010 [maven-release-plugin] rollback the release of v2.5.0
add 6ebccc730 Changes to enable javadoc step to complete.
add 93f33735f Reset version from 2.6.0-SNAPSHOT to 2.5.0-SNAPSHOT
add e71422017 Change tasks tag to target tag
add 80d6fa5a0 Remove transitive dependency to activemq-protobuf to avoid
failure in "mvn deploy"
add e10164dc0 [maven-release-plugin] prepare release v2.5.0
add 20695cd42 [maven-release-plugin] prepare for next development iteration
add 82eae2f37 [maven-release-plugin] rollback the release of v2.5.0
add 096141db1 hnage storm-dist version to 2.5.0-SNAPSHOT and exclude
activemq-protobug in storm-mqtt-examples
add a20afb89f [maven-release-plugin] prepare release v2.5.0
add 5a6747110 [maven-release-plugin] prepare for next development iteration
add 11cdf16df [maven-release-plugin] rollback the release of v2.5.0
add 3da85e154 Reset version in storm-dist to 2.5.0-SNAPSHOT
add 9441cea2e Exclude activemq-protobuf from all transitive dependencies.
add 20fae02d2 Rollback release and update DEPENDENCY-LICENSES to remove
activemq-protobuf
add 6c209a738 [maven-release-plugin] prepare release v2.5.0
add 599c177e9 [maven-release-plugin] prepare for next development iteration
add a3c78e474 [STORM-3895] Add JDK-17 build (#3555)
add d1f914607 Missing dependency prevents Storm from being built, fixes
#3940
add 516d383d9 Merge pull request #3556 from DigitalPebble/3940
add 710d86811 [maven-release-plugin] prepare release v2.5.0
add 646cfc270 [maven-release-plugin] prepare for next development iteration
add 3455f9c06 STORM-3941 - Add .asf.yaml to GitHub repository
add 013779b39 [STORM-3939] Remove gitact build for JDK 8, set class format
to JDK11, and allow introspection as needed. (#3558)
add 0eaced227 synchronize access to map in Multi*Metric; fixes STORM-3944
add d7851dcac Merge pull request #3559 from DigitalPebble/3944
add dd4516a13 [STORM-3884] Update calcite to 1.16.0 (#3510)
add f1a792830 [STORM-3901] Upgrade Kryo to version 5.4.0 and remove
reflectasm-shaded (#3526)
add 8035dd1aa allow WorkerHooks to set TopContext userResources
add 31b3e90c4 swap WorkerTopologyContext with WorkerUserContext
add c2758d006 add integration test
add ada43e481 update docs
add 1401c0b84 add unit tests
add c69ade3bc add inline documentation and update README
add 77e1cfa84 formatting fixes
add a1a49a428 Merge pull request #3547 from
6harat/feature/worker-usercontext
add 372658b88 [STORM-3800] fix resource leak due to Files.walk Files.list
(#3416)
add ca7248165 Fix checkstyle violations from latest pull request
add bef87d8d9 STORM-3945 - Upgrade Zookeeper to 3.9.0 & Curator 5.5.0
(#3560)
add fe8d89f1d STORM-3948 - Hive 2.3.9 declares an offline / unmaintained
maven repository
add fc0859e36 STORM-3947 - Align Netty with version used in Zookeeper
add 1c7b7ddba [STORM-3845] Update Active MQ version to 5.18.2 (#3463)
add 04b881485 [STORM-3792] Change forkCount from 1 to 1.0C and
reuseForks=false (#3410)
add b07483402 [STORM-3762] Set a default character set in
InputStreamReader to solve potential garbled problems (#3393)
add 9259006a3 [STORM-3771] Execute doCleanup in its own timer thread
without lock. (#3397)
add 40b982227 [STORM-3782] Refactor KafkaOffsetMetric to use V2 metrics
(#3404)
add e32bcd4da STORM-3914 - Several External Modules as not being tested
for JDK 11 (#3561)
add c961e24a1 STORM-3950 - Modernize storm-jdbc
add c0b71c91a Bump org.apache.maven:maven-core
add b2523d52b [STORM-3955] update DEPENDENCY-LICENSES mvn
license:aggregate-add-third-party@generate-and-check-licenses
-Dlicense.skipAggregateAddThirdParty=false -B
add d1d0e1bd8 [STORM-3953] Update releasing document. (#3568)
add e71645a78 [STORM-3949] libthrift 0.18.1 (#3564)
add dee42393e STORM-3954 - Remove Logback pulled in by Zookeeper (#3569)
add 939d92c6d Fix cli monitor component's argument type
add 45d141cc2 support worker hook declaration in flux
add 374eee25c updating flux README
add f75ab7853 minor correction in flux README
add 96cc304b0 update README
add c7cb4139a Update Common-patterns.md
add 25bc87060 Update Classpath-handling.md
add d8604d03c Update ClusterMetrics.md
add 15e5e371e Update NUMA.md
add 36a118613 Update Performance.md
add 465b97a62 STORM-3885 - Jackson 2.15.2
add 90a229ea2 STORM-3885 - License Adjustment
add 59769f1d1 STORM-3885 - License Adjustment
add 911afe2c0 STORM-3937 - Fix errors/warnings found while generating
javadoc in storm-starter
add 2439a2b69 STORM-3936 - Fix errors/warnings found while generating
javadoc in storm-kafka-client
add a798cd6f6 STORM-3935 - Fix errors/warnings found while generating
javadoc in storm-cassandra
add 2ec7a7413 STORM-3934 - Fix errors/warnings found while generating
javadoc in storm-webapps (documents impl details)
add fc7bd5f68 STORM-3933 - Fix errors/warnings found while generating
javadoc in storm-server
add 4521994fd STORM-3932 - Fix errors/warnings found while generating
javadoc in storm-client
add 19f993ee0 [STORM-3967] Specify generated sources directory. (#3576)
add 2f7f35057 [STORM-3965] Allow reflection access to java.nio for
protobug in JDK11 and above. (#3574)
add 0e9c744bb [STORM-3968] Add missing groupId in storm-core/pom.xml for
maven-dependency-plugin
add 99f3b54ba Merge pull request #3577 from bipinprasad/storm-3968
add 06fa5b9dc HdfsBlobStoreFile set wrong permission for file
add 32cab5573 Merge pull request #3506 from skysiders/STORM-3888
add 9b5ea17a7 [STORM-3970] Changes to storm-sql-core/pom.xml to avoid
errors in Eclipse
add 4f99de0c5 Merge pull request #3578 from bipinprasad/storm-3970
add 1406f680c STORM-3961 - Modernize Storm-UI Dependencies (#3572)
add 8db4c4fac [STORM-3963] Add m2e plugin to storm-shaded-deps and few
minor pom.xml fixes.
add 7c5ae53ee Merge pull request #3573 from bipinprasad/storm-3963
add a837e6add Updates developer docs and removing obsolete content
add b778125a1 Replace File.createTempFile with
java.nio.file.Files.createTempFile
add 4374fdc93 Merge pull request #3582 from apache/tempFiles
add f28798e9e STORM-3958: Capacity to set Storm UI's title in
conf/storm.yaml
add e72807e6b STORM-3982 - Updates README, POM.xml and DOAP file
add 8b28818da STORM-3984: Nimbus failover causes unnecessary reassign if
600s are passed after starting Nimbus.
add 304645d92 Merge pull request #3583 from iwasakims/STORM-3984
add e73009ba4 STORM-3988 - Remove "storm-cassandra"
add 7f97a03aa STORM-3988 - Remove "storm-eventhubs"
add 7adbe83b3 STORM-3988 - Remove "storm-hbase"
add 78b799cb2 STORM-3988 - Remove "storm-kinesis"
add ee7d71c5e STORM-3988 - Remove "storm-mongodb"
add 8a2070dfb STORM-3988 - Remove "storm-mqtt"
add 50bb8c49e STORM-3988 - Remove "storm-opentsdb"
add 6c09b6e26 STORM-3988 - Remove "storm-pmml"
add e9db2b848 STORM-3988 - Remove "storm-pulsar"
add e655c6d88 STORM-3988 - Remove "storm-rocketmq"
add 80a29c925 STORM-3988 - Remove "storm-solr"
add 4dd83d7b8 STORM-3988 - Remove "storm-sql-mongodb"
add 782b0d8f5 STORM-3988 - Fix licenses after module removal
add 88c7d8985 STORM-3988 - Remove content from /docs
add 1c6c7f0a0 Bump org.apache.zookeeper:zookeeper from 3.9.0 to 3.9.1
add 163f51d95 Fix license
add b6de024d1 Bump org.xerial.snappy:snappy-java from 1.1.10.3 to 1.1.10.4
add 46ce5f18f Fix license for snappy-java
add 0da46cb58 Merge remote-tracking branch 'origin/master' into STORM-3988
add 964ca2666 STORM-3991 - Bump org.apache.avro:avro from 1.7.7 to 1.11.3
in /sql/storm-sql-runtime (#3585)
add 4c82ee948 Merge remote-tracking branch 'origin/master' into STORM-3988
add c9e181c83 STORM-3990 - Hadoop 2.10.2 (#3589)
add e1efb4a3f Merge remote-tracking branch 'origin/master' into STORM-3988
add d2e670a66 Fix license
add 51480142b Merge pull request #3588 from apache/STORM-3988
add 7194ac4e1 [STORM-3966] Allow reflection in JDK11 test for
storm-sql-hdfs; update guava version (#3575)
add b2ee6177d Merge branch 'master' into
dependabot/maven/org.apache.hadoop-hadoop-common-3.2.3
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 33 +
.gitattributes | 17 +
.github/workflows/maven.yaml | 72 +
.gitignore | 1 -
.travis.yml | 72 -
DEPENDENCY-LICENSES | 505 +++----
DEVELOPER.md | 48 +-
LICENSE-binary | 352 ++---
README.markdown | 76 +-
RELEASING.md | 184 ++-
SECURITY.md | 13 +-
aws-bin/README | 8 +
aws-bin/aws_kafka.py | 234 +++
.../src/py_license_header.txt => aws-bin/init.sh | 6 +-
bin/docker-to-squash.py | 1171 ++++++++++-----
bin/storm | 6 +-
bin/storm.ps1 | 8 +-
bin/storm.py | 97 +-
bin/test_docker_to_squash.py | 50 +
bin/test_storm.py | 217 +++
conf/defaults.yaml | 6 +-
dev-tools/find-checkstyle-issues.py | 8 +-
dev-tools/gitact/gitact-install.sh | 51 +
.../travis-script.sh => gitact/gitact-script.sh} | 39 +-
.../print-errors-from-test-reports.py | 0
dev-tools/{travis => gitact}/ratprint.py | 12 +-
dev-tools/{travis => gitact}/requirements.txt | 0
dev-tools/{travis => gitact}/save-logs.py | 23 +-
dev-tools/github/__init__.py | 32 +-
dev-tools/jira-github-join.py | 17 +-
dev-tools/jira_github/__init__.py | 97 +-
dev-tools/release_notes.py | 84 +-
dev-tools/report/__init__.py | 2 +-
dev-tools/report/formatter.py | 16 +-
dev-tools/report/report.py | 49 +-
dev-tools/report/report_builder.py | 10 +-
dev-tools/storm-merge.py | 24 +-
dev-tools/travis/travis-install.sh | 52 -
dev-tools/validate-license-files.py | 30 +-
doap_Storm.rdf | 6 +-
docs/Classpath-handling.md | 6 +-
docs/Clojure-DSL.md | 2 +-
docs/ClusterMetrics.md | 12 +-
docs/Command-line-client.md | 2 +-
docs/Common-patterns.md | 10 +-
docs/Defining-a-non-jvm-language-dsl-for-storm.md | 13 +-
docs/Hooks.md | 15 +-
docs/Metrics.md | 2 +-
docs/Multilang-protocol.md | 10 +-
docs/NUMA.md | 8 +-
docs/OCI-support.md | 4 +-
docs/Performance.md | 20 +-
docs/Resource_Aware_Scheduler_overview.md | 1 +
docs/Setting-up-a-Storm-cluster.md | 4 +-
docs/Stream-API.md | 2 +-
docs/Tutorial.md | 6 +-
docs/Using-non-JVM-languages-with-Storm.md | 12 +-
docs/Windowing.md | 2 +-
docs/distcache-blobstore.md | 5 +-
docs/flux.md | 21 +-
docs/storm-cassandra.md | 235 ---
docs/storm-eventhubs.md | 40 -
docs/storm-hbase.md | 290 ----
docs/storm-hive.md | 111 --
docs/storm-jms-example.md | 8 +-
docs/storm-jms-spring.md | 2 +-
docs/storm-kinesis.md | 145 --
docs/storm-mongodb.md | 303 ----
docs/storm-mqtt.md | 379 -----
docs/storm-opentsdb.md | 56 -
docs/storm-pmml.md | 42 -
docs/storm-rocketmq.md | 98 --
docs/storm-solr.md | 190 ---
docs/storm-sql-example.md | 12 +-
examples/storm-elasticsearch-examples/pom.xml | 2 +-
examples/storm-hbase-examples/README.md | 62 -
examples/storm-hbase-examples/pom.xml | 96 --
.../storm/hbase/topology/LookupWordCount.java | 68 -
.../storm/hbase/topology/PersistentWordCount.java | 79 -
.../storm/hbase/topology/TotalWordCounter.java | 68 -
.../storm/hbase/topology/WordCountClient.java | 54 -
.../storm/hbase/topology/WordCountValueMapper.java | 62 -
.../apache/storm/hbase/topology/WordCounter.java | 56 -
.../org/apache/storm/hbase/topology/WordSpout.java | 87 --
.../apache/storm/hbase/trident/PrintFunction.java | 34 -
.../storm/hbase/trident/WordCountTrident.java | 94 --
examples/storm-hdfs-examples/pom.xml | 2 +-
examples/storm-hive-examples/pom.xml | 2 +-
examples/storm-jdbc-examples/pom.xml | 2 +-
examples/storm-jms-examples/pom.xml | 4 +-
examples/storm-kafka-client-examples/pom.xml | 3 +-
examples/storm-loadgen/pom.xml | 6 +-
.../java/org/apache/storm/loadgen/CaptureLoad.java | 9 +-
.../apache/storm/loadgen/ThroughputVsLatency.java | 4 -
.../org/apache/storm/loadgen/TopologyLoadConf.java | 7 +-
.../org/apache/storm/loadgen/LoadCompConfTest.java | 8 +-
.../storm/loadgen/LoadMetricsServerTest.java | 9 +-
.../apache/storm/loadgen/NormalDistStatsTest.java | 14 +-
.../org/apache/storm/loadgen/OutputStreamTest.java | 6 +-
examples/storm-mongodb-examples/pom.xml | 96 --
.../storm/mongodb/topology/InsertWordCount.java | 72 -
.../storm/mongodb/topology/LookupWordCount.java | 76 -
.../storm/mongodb/topology/TotalWordCounter.java | 74 -
.../storm/mongodb/topology/UpdateWordCount.java | 83 --
.../apache/storm/mongodb/topology/WordCounter.java | 71 -
.../apache/storm/mongodb/topology/WordSpout.java | 94 --
.../storm/mongodb/trident/PrintFunction.java | 41 -
.../storm/mongodb/trident/WordCountTrident.java | 87 --
.../storm/mongodb/trident/WordCountTridentMap.java | 89 --
examples/storm-mqtt-examples/pom.xml | 128 --
.../storm-mqtt-examples/src/main/flux/sample.yaml | 62 -
.../src/main/flux/ssl-sample.yaml | 78 -
.../storm/mqtt/examples/CustomMessageMapper.java | 79 -
.../storm/mqtt/examples/MqttBrokerPublisher.java | 137 --
.../apache/storm/mqtt/examples/package-info.java | 20 -
.../src/main/resources/log4j2.xml | 32 -
examples/storm-opentsdb-examples/pom.xml | 96 --
.../apache/storm/opentsdb/MetricGenBatchSpout.java | 96 --
.../org/apache/storm/opentsdb/MetricGenSpout.java | 74 -
.../storm/opentsdb/SampleOpenTsdbBoltTopology.java | 61 -
.../opentsdb/SampleOpenTsdbTridentTopology.java | 77 -
examples/storm-perf/pom.xml | 3 +-
examples/storm-pmml-examples/pom.xml | 96 --
.../apache/storm/pmml/JpmmlRunnerTestTopology.java | 195 ---
.../apache/storm/pmml/RawInputFromCSVSpout.java | 133 --
.../src/main/resources/Audit.50.csv | 51 -
...KNIME_PMML_4.1_Examples_single_audit_logreg.xml | 259 ----
.../src/main/resources/README.md | 6 -
examples/storm-redis-examples/pom.xml | 2 +-
examples/storm-rocketmq-examples/pom.xml | 96 --
.../storm/rocketmq/topology/WordCountTopology.java | 89 --
.../storm/rocketmq/topology/WordCounter.java | 68 -
.../storm/rocketmq/trident/WordCountTrident.java | 89 --
examples/storm-solr-examples/pom.xml | 127 --
.../apache/storm/solr/spout/SolrFieldsSpout.java | 77 -
.../org/apache/storm/solr/spout/SolrJsonSpout.java | 117 --
.../storm/solr/topology/SolrFieldsTopology.java | 61 -
.../storm/solr/topology/SolrJsonTopology.java | 49 -
.../apache/storm/solr/topology/SolrTopology.java | 71 -
.../solr/trident/SolrFieldsTridentTopology.java | 48 -
.../solr/trident/SolrJsonTridentTopology.java | 46 -
.../java/org/apache/storm/solr/util/TestUtil.java | 30 -
examples/storm-starter/pom.xml | 4 +-
.../starter/BlobStoreAPIWordCountTopology.java | 2 +-
.../storm/starter/SlidingWindowTopology.java | 4 +-
.../apache/storm/starter/WordCountTopology.java | 2 +-
.../storm/starter/streams/TypedTupleExample.java | 2 +-
.../storm/starter/tools/SlidingWindowCounter.java | 7 +-
.../starter/bolt/IntermediateRankingsBoltTest.java | 8 +-
.../storm/starter/bolt/RollingCountBoltTest.java | 6 +-
.../storm/starter/bolt/TotalRankingsBoltTest.java | 8 +-
.../tools/RankableObjectWithFieldsTest.java | 9 +-
external/storm-autocreds/pom.xml | 49 +-
external/storm-blobstore-migration/pom.xml | 47 +-
external/storm-cassandra/README.md | 390 -----
external/storm-cassandra/pom.xml | 140 --
.../cassandra/AbstractExecutionResultHandler.java | 55 -
.../cassandra/BaseExecutionResultHandler.java | 89 --
.../apache/storm/cassandra/CassandraContext.java | 84 --
.../storm/cassandra/DynamicStatementBuilder.java | 153 --
.../storm/cassandra/ExecutionResultHandler.java | 94 --
.../storm/cassandra/Murmur3StreamGrouping.java | 121 --
.../storm/cassandra/bolt/BaseCassandraBolt.java | 205 ---
.../cassandra/bolt/BatchCassandraWriterBolt.java | 196 ---
.../storm/cassandra/bolt/CassandraWriterBolt.java | 59 -
.../storm/cassandra/bolt/GroupingBatchBuilder.java | 57 -
.../cassandra/bolt/PairBatchStatementTuples.java | 45 -
.../storm/cassandra/bolt/PairStatementTuple.java | 42 -
.../storm/cassandra/client/CassandraConf.java | 320 ----
.../storm/cassandra/client/ClusterFactory.java | 73 -
.../storm/cassandra/client/SimpleClient.java | 36 -
.../cassandra/client/SimpleClientProvider.java | 29 -
.../storm/cassandra/client/impl/DefaultClient.java | 119 --
.../storm/cassandra/context/BaseBeanFactory.java | 64 -
.../storm/cassandra/context/BeanFactory.java | 40 -
.../apache/storm/cassandra/context/WorkerCtx.java | 85 --
.../storm/cassandra/executor/AsyncExecutor.java | 307 ----
.../cassandra/executor/AsyncExecutorProvider.java | 34 -
.../cassandra/executor/AsyncResultHandler.java | 57 -
.../cassandra/executor/AsyncResultSetHandler.java | 51 -
.../executor/ExecutionResultCollector.java | 97 --
.../executor/impl/BatchAsyncResultHandler.java | 67 -
.../executor/impl/SingleAsyncResultHandler.java | 66 -
.../query/AyncCQLResultSetValuesMapper.java | 30 -
.../query/BaseCQLStatementTupleMapper.java | 44 -
.../cassandra/query/CQLResultSetValuesMapper.java | 27 -
.../storm/cassandra/query/CQLStatementBuilder.java | 25 -
.../cassandra/query/CQLStatementTupleMapper.java | 56 -
.../org/apache/storm/cassandra/query/Column.java | 76 -
.../apache/storm/cassandra/query/ContextQuery.java | 96 --
.../apache/storm/cassandra/query/CqlMapper.java | 81 -
.../cassandra/query/ObjectMapperOperation.java | 29 -
.../builder/BoundCQLStatementMapperBuilder.java | 98 --
.../ObjectMapperCqlStatementMapperBuilder.java | 88 --
.../builder/SimpleCQLStatementMapperBuilder.java | 86 --
.../query/impl/BatchCQLStatementTupleMapper.java | 50 -
.../query/impl/BoundCQLStatementTupleMapper.java | 93 --
.../query/impl/ObjectMapperCqlStatementMapper.java | 134 --
.../query/impl/PreparedStatementBinder.java | 63 -
.../cassandra/query/impl/RoutingKeyGenerator.java | 45 -
.../query/impl/SimpleCQLStatementMapper.java | 80 -
.../cassandra/query/selector/FieldSelector.java | 65 -
.../trident/state/CassandraBackingMap.java | 235 ---
.../trident/state/CassandraMapStateFactory.java | 98 --
.../cassandra/trident/state/CassandraQuery.java | 34 -
.../cassandra/trident/state/CassandraState.java | 150 --
.../trident/state/CassandraStateFactory.java | 42 -
.../trident/state/CassandraStateUpdater.java | 26 -
.../trident/state/MapStateFactoryBuilder.java | 224 ---
.../state/NonTransactionalTupleStateMapper.java | 57 -
.../trident/state/OpaqueTupleStateMapper.java | 119 --
.../trident/state/SerializedStateMapper.java | 58 -
.../cassandra/trident/state/SimpleStateMapper.java | 96 --
.../storm/cassandra/trident/state/SimpleTuple.java | 205 ---
.../storm/cassandra/trident/state/StateMapper.java | 28 -
.../state/TransactionalTupleStateMapper.java | 98 --
.../state/TridentAyncCQLResultSetValuesMapper.java | 110 --
.../state/TridentResultSetValuesMapper.java | 53 -
.../org/apache/storm/cassandra/WeatherSpout.java | 77 -
.../testtools/EmbeddedCassandraResource.java | 182 ---
.../storm/cassandra/trident/MapStateTest.java | 226 ---
.../storm/cassandra/trident/WeatherBatchSpout.java | 95 --
.../src/test/resources/cassandra.yaml | 39 -
external/storm-elasticsearch/pom.xml | 19 +-
.../storm/elasticsearch/bolt/EsIndexBoltTest.java | 12 +-
.../bolt/EsLookupBoltIntegrationTest.java | 24 +-
.../storm/elasticsearch/bolt/EsLookupBoltTest.java | 15 +-
.../elasticsearch/bolt/EsPercolateBoltTest.java | 11 +-
.../storm/elasticsearch/common/EsConfigTest.java | 6 +-
external/storm-eventhubs/README.md | 45 -
external/storm-eventhubs/pom.xml | 85 --
.../eventhubs/bolt/DefaultEventDataFormat.java | 47 -
.../apache/storm/eventhubs/bolt/EventHubBolt.java | 139 --
.../storm/eventhubs/bolt/EventHubBoltConfig.java | 108 --
.../storm/eventhubs/bolt/IEventDataFormat.java | 29 -
.../eventhubs/spout/BinaryEventDataScheme.java | 72 -
.../storm/eventhubs/spout/EventDataScheme.java | 75 -
.../storm/eventhubs/spout/EventDataWrap.java | 48 -
.../storm/eventhubs/spout/EventHubException.java | 41 -
.../storm/eventhubs/spout/EventHubFilter.java | 47 -
.../eventhubs/spout/EventHubReceiverImpl.java | 169 ---
.../storm/eventhubs/spout/EventHubSpout.java | 258 ----
.../storm/eventhubs/spout/EventHubSpoutConfig.java | 264 ----
.../storm/eventhubs/spout/FieldConstants.java | 29 -
.../storm/eventhubs/spout/IEventDataScheme.java | 44 -
.../apache/storm/eventhubs/spout/IEventFilter.java | 28 -
.../storm/eventhubs/spout/IEventHubReceiver.java | 34 -
.../eventhubs/spout/IEventHubReceiverFactory.java | 25 -
.../eventhubs/spout/IPartitionCoordinator.java | 28 -
.../storm/eventhubs/spout/IPartitionManager.java | 38 -
.../eventhubs/spout/IPartitionManagerFactory.java | 28 -
.../apache/storm/eventhubs/spout/IStateStore.java | 32 -
.../apache/storm/eventhubs/spout/MessageId.java | 57 -
.../storm/eventhubs/spout/PartitionManager.java | 101 --
.../eventhubs/spout/SerializeDeserializeUtil.java | 34 -
.../eventhubs/spout/SimplePartitionManager.java | 133 --
.../spout/StaticPartitionCoordinator.java | 84 --
.../eventhubs/spout/StringEventDataScheme.java | 71 -
.../storm/eventhubs/spout/ZookeeperStateStore.java | 96 --
.../storm/eventhubs/trident/Coordinator.java | 59 -
.../trident/ITridentPartitionManager.java | 37 -
.../trident/ITridentPartitionManagerFactory.java | 26 -
.../trident/OpaqueTridentEventHubEmitter.java | 69 -
.../trident/OpaqueTridentEventHubSpout.java | 63 -
.../apache/storm/eventhubs/trident/Partition.java | 40 -
.../apache/storm/eventhubs/trident/Partitions.java | 43 -
.../TransactionalTridentEventHubEmitter.java | 161 --
.../trident/TransactionalTridentEventHubSpout.java | 64 -
.../eventhubs/trident/TridentPartitionManager.java | 89 --
.../src/main/resources/config.properties | 45 -
.../eventhubs/samples/AtMostOnceEventCount.java | 54 -
.../apache/storm/eventhubs/samples/EventCount.java | 144 --
.../storm/eventhubs/samples/EventHubLoop.java | 52 -
.../eventhubs/samples/OpaqueTridentEventCount.java | 54 -
.../samples/TransactionalTridentEventCount.java | 81 -
.../eventhubs/samples/bolt/GlobalCountBolt.java | 87 --
.../eventhubs/samples/bolt/PartialCountBolt.java | 67 -
.../eventhubs/spout/EventHubReceiverMock.java | 84 --
.../eventhubs/spout/EventHubSpoutCallerMock.java | 92 --
.../spout/PartitionManagerCallerMock.java | 95 --
.../eventhubs/spout/SpoutOutputCollectorMock.java | 71 -
.../storm/eventhubs/spout/StateStoreMock.java | 54 -
.../storm/eventhubs/spout/TestEventData.java | 48 -
.../storm/eventhubs/spout/TestEventHubSpout.java | 75 -
.../eventhubs/spout/TestPartitionManager.java | 119 --
.../trident/TestTransactionalTridentEmitter.java | 92 --
.../eventhubs/trident/TridentCollectorMock.java | 57 -
external/storm-hbase/README.md | 315 ----
external/storm-hbase/pom.xml | 127 --
.../apache/storm/hbase/bolt/AbstractHBaseBolt.java | 82 --
.../org/apache/storm/hbase/bolt/HBaseBolt.java | 114 --
.../apache/storm/hbase/bolt/HBaseLookupBolt.java | 117 --
.../storm/hbase/bolt/mapper/HBaseMapper.java | 35 -
.../hbase/bolt/mapper/HBaseProjectionCriteria.java | 87 --
.../storm/hbase/bolt/mapper/HBaseValueMapper.java | 36 -
.../storm/hbase/bolt/mapper/SimpleHBaseMapper.java | 85 --
.../org/apache/storm/hbase/common/ColumnList.java | 198 ---
.../org/apache/storm/hbase/common/HBaseClient.java | 181 ---
.../org/apache/storm/hbase/common/IColumn.java | 26 -
.../org/apache/storm/hbase/common/ICounter.java | 24 -
.../java/org/apache/storm/hbase/common/Utils.java | 123 --
.../storm/hbase/state/HBaseKeyValueState.java | 434 ------
.../hbase/state/HBaseKeyValueStateIterator.java | 146 --
.../hbase/state/HBaseKeyValueStateProvider.java | 165 ---
.../mapper/SimpleTridentHBaseMapMapper.java | 50 -
.../trident/mapper/SimpleTridentHBaseMapper.java | 79 -
.../trident/mapper/TridentHBaseMapMapper.java | 34 -
.../hbase/trident/mapper/TridentHBaseMapper.java | 40 -
.../storm/hbase/trident/state/HBaseMapState.java | 264 ----
.../storm/hbase/trident/state/HBaseQuery.java | 35 -
.../storm/hbase/trident/state/HBaseState.java | 171 ---
.../hbase/trident/state/HBaseStateFactory.java | 34 -
.../storm/hbase/trident/state/HBaseUpdater.java | 27 -
.../hbase/trident/windowing/HBaseWindowsStore.java | 267 ----
.../windowing/HBaseWindowsStoreFactory.java | 48 -
.../storm/hbase/state/HBaseClientTestUtil.java | 387 -----
.../state/HBaseKeyValueStateIteratorTest.java | 213 ---
.../state/HBaseKeyValueStateProviderTest.java | 95 --
.../storm/hbase/state/HBaseKeyValueStateTest.java | 114 --
external/storm-hdfs-blobstore/pom.xml | 52 +-
.../storm/hdfs/blobstore/HdfsBlobStoreFile.java | 2 +-
.../apache/storm/hdfs/blobstore/BlobStoreTest.java | 60 +-
.../hdfs/blobstore/HdfsBlobStoreImplTest.java | 177 ++-
external/storm-hdfs-oci/pom.xml | 10 +-
external/storm-hdfs/pom.xml | 72 +-
.../storm/hdfs/avro/AbstractAvroSerializer.java | 2 +-
.../storm/hdfs/avro/TestFixedAvroSerializer.java | 18 +-
.../storm/hdfs/avro/TestGenericAvroSerializer.java | 18 +-
.../storm/hdfs/bolt/AvroGenericRecordBoltTest.java | 53 +-
.../org/apache/storm/hdfs/bolt/TestHdfsBolt.java | 61 +-
.../storm/hdfs/bolt/TestSequenceFileBolt.java | 46 +-
.../org/apache/storm/hdfs/bolt/TestWritersMap.java | 25 +-
.../hdfs/bolt/format/TestSimpleFileNameFormat.java | 17 +-
.../org/apache/storm/hdfs/spout/ConfigsTest.java | 4 +-
.../org/apache/storm/hdfs/spout/TestDirLock.java | 59 +-
.../org/apache/storm/hdfs/spout/TestFileLock.java | 140 +-
.../apache/storm/hdfs/spout/TestHdfsSemantics.java | 53 +-
.../org/apache/storm/hdfs/spout/TestHdfsSpout.java | 148 +-
.../storm/hdfs/spout/TestProgressTracker.java | 55 +-
.../hdfs/testing/MiniDFSClusterExtension.java | 33 +
...java => MiniDFSClusterExtensionClassLevel.java} | 19 +-
.../storm/hdfs/testing/MiniDFSClusterRule.java | 75 -
.../apache/storm/hdfs/trident/HdfsStateTest.java | 39 +-
.../trident/format/TestSimpleFileNameFormat.java | 21 +-
external/storm-hive/pom.xml | 49 +-
.../hive/bolt/mapper/JsonRecordHiveMapper.java | 3 +-
.../org/apache/storm/hive/bolt/TestHiveBolt.java | 44 +-
.../apache/storm/hive/common/TestHiveWriter.java | 15 +-
external/storm-jdbc/pom.xml | 11 +-
.../apache/storm/jdbc/bolt/AbstractJdbcBolt.java | 2 +-
.../org/apache/storm/jdbc/bolt/JdbcInsertBolt.java | 5 +-
.../org/apache/storm/jdbc/bolt/JdbcLookupBolt.java | 2 +-
.../jdbc/common/HikariCPConnectionProvider.java | 2 +-
.../org/apache/storm/jdbc/common/JdbcClient.java | 2 +-
.../storm/jdbc/mapper/SimpleJdbcLookupMapper.java | 2 +-
.../apache/storm/jdbc/mapper/SimpleJdbcMapper.java | 2 +-
.../apache/storm/jdbc/bolt/JdbcInsertBoltTest.java | 36 +-
.../apache/storm/jdbc/bolt/JdbcLookupBoltTest.java | 24 +-
.../apache/storm/jdbc/common/JdbcClientTest.java | 43 +-
.../org/apache/storm/jdbc/common/UtilTest.java | 25 +-
external/storm-jms/pom.xml | 8 +-
.../org/apache/storm/jms/spout/JmsSpoutTest.java | 18 +-
external/storm-kafka-client/pom.xml | 5 +-
.../org/apache/storm/kafka/bolt/KafkaBolt.java | 4 +-
.../org/apache/storm/kafka/spout/KafkaSpout.java | 25 +-
.../org/apache/storm/kafka/spout/KafkaTuple.java | 2 +-
.../kafka/spout/metrics/KafkaOffsetMetric.java | 151 --
.../spout/metrics2/KafkaOffsetMetricManager.java | 85 ++
.../metrics2/KafkaOffsetPartitionMetrics.java | 205 +++
.../spout/metrics2/KafkaOffsetTopicMetrics.java | 139 ++
.../kafka/spout/subscription/TopicAssigner.java | 7 +-
.../org/apache/storm/kafka/bolt/KafkaBoltTest.java | 2 +-
.../kafka/spout/ByTopicRecordTranslatorTest.java | 31 +-
.../kafka/spout/DefaultRecordTranslatorTest.java | 10 +-
.../storm/kafka/spout/KafkaSpoutEmitTest.java | 14 +-
.../spout/KafkaSpoutLogCompactionSupportTest.java | 30 +-
.../spout/KafkaSpoutMessagingGuaranteeTest.java | 40 +-
.../kafka/spout/KafkaSpoutReactivationTest.java | 22 +-
.../storm/kafka/spout/KafkaSpoutRebalanceTest.java | 59 +-
.../KafkaSpoutRetryExponentialBackoffTest.java | 29 +-
.../kafka/spout/KafkaSpoutRetryLimitTest.java | 27 +-
.../kafka/spout/KafkaSpoutSingleTopicTest.java | 58 +-
...aSpoutTopologyDeployActivateDeactivateTest.java | 3 +
.../kafka/spout/MaxUncommittedOffsetTest.java | 14 +-
.../kafka/spout/SimpleRecordTranslatorTest.java | 16 +-
.../spout/SpoutWithMockedConsumerSetupHelper.java | 5 +-
.../spout/subscription/NamedTopicFilterTest.java | 8 +-
.../spout/subscription/PatternTopicFilterTest.java | 8 +-
.../RoundRobinManualPartitionerTest.java | 10 +-
.../spout/subscription/TopicAssignerTest.java | 2 +-
.../KafkaTridentSpoutBatchMetadataTest.java | 18 +-
.../trident/KafkaTridentSpoutEmitterEmitTest.java | 14 +-
.../KafkaTridentSpoutEmitterPartitioningTest.java | 4 +-
.../KafkaTridentSpoutOpaqueCoordinatorTest.java | 8 +-
external/storm-kafka-migration/pom.xml | 2 +-
external/storm-kafka-monitor/README.md | 10 +-
external/storm-kafka-monitor/pom.xml | 10 +-
.../storm/kafka/monitor/KafkaOffsetLagResult.java | 2 +-
.../storm/kafka/monitor/KafkaOffsetLagUtil.java | 2 +-
external/storm-kinesis/README.md | 140 --
external/storm-kinesis/pom.xml | 73 -
.../kinesis/spout/CredentialsProviderChain.java | 40 -
.../kinesis/spout/ExponentialBackoffRetrier.java | 169 ---
.../kinesis/spout/FailedMessageRetryHandler.java | 48 -
.../apache/storm/kinesis/spout/KinesisConfig.java | 144 --
.../storm/kinesis/spout/KinesisConnection.java | 121 --
.../storm/kinesis/spout/KinesisConnectionInfo.java | 115 --
.../storm/kinesis/spout/KinesisMessageId.java | 81 -
.../storm/kinesis/spout/KinesisRecordsManager.java | 486 ------
.../apache/storm/kinesis/spout/KinesisSpout.java | 86 --
.../storm/kinesis/spout/RecordToTupleMapper.java | 40 -
.../apache/storm/kinesis/spout/ZkConnection.java | 97 --
.../org/apache/storm/kinesis/spout/ZkInfo.java | 124 --
.../storm/kinesis/spout/test/KinesisBoltTest.java | 48 -
.../kinesis/spout/test/KinesisSpoutTopology.java | 57 -
.../spout/test/TestRecordToTupleMapper.java | 58 -
external/storm-metrics/pom.xml | 6 +-
external/storm-mongodb/README.md | 325 ----
external/storm-mongodb/pom.xml | 82 --
.../storm/mongodb/bolt/AbstractMongoBolt.java | 62 -
.../apache/storm/mongodb/bolt/MongoInsertBolt.java | 124 --
.../apache/storm/mongodb/bolt/MongoLookupBolt.java | 86 --
.../apache/storm/mongodb/bolt/MongoUpdateBolt.java | 93 --
.../apache/storm/mongodb/common/MongoDbClient.java | 109 --
.../apache/storm/mongodb/common/MongoUtils.java | 44 -
.../storm/mongodb/common/QueryFilterCreator.java | 47 -
.../mongodb/common/SimpleQueryFilterCreator.java | 47 -
.../mongodb/common/mapper/MongoLookupMapper.java | 45 -
.../storm/mongodb/common/mapper/MongoMapper.java | 47 -
.../mongodb/common/mapper/MongoUpdateMapper.java | 26 -
.../common/mapper/SimpleMongoLookupMapper.java | 64 -
.../mongodb/common/mapper/SimpleMongoMapper.java | 55 -
.../common/mapper/SimpleMongoUpdateMapper.java | 47 -
.../storm/mongodb/trident/state/MongoMapState.java | 213 ---
.../storm/mongodb/trident/state/MongoState.java | 145 --
.../mongodb/trident/state/MongoStateFactory.java | 43 -
.../mongodb/trident/state/MongoStateQuery.java | 41 -
.../mongodb/trident/state/MongoStateUpdater.java | 35 -
external/storm-mqtt/README.md | 375 -----
external/storm-mqtt/pom.xml | 143 --
.../java/org/apache/storm/mqtt/MqttLogger.java | 30 -
.../java/org/apache/storm/mqtt/MqttMessage.java | 37 -
.../org/apache/storm/mqtt/MqttMessageMapper.java | 38 -
.../org/apache/storm/mqtt/MqttTupleMapper.java | 31 -
.../java/org/apache/storm/mqtt/bolt/MqttBolt.java | 97 --
.../org/apache/storm/mqtt/common/MqttOptions.java | 301 ----
.../apache/storm/mqtt/common/MqttPublisher.java | 59 -
.../org/apache/storm/mqtt/common/MqttUtils.java | 82 --
.../org/apache/storm/mqtt/common/SslUtils.java | 57 -
.../storm/mqtt/mappers/ByteArrayMessageMapper.java | 31 -
.../storm/mqtt/mappers/StringMessageMapper.java | 34 -
.../apache/storm/mqtt/spout/AckableMessage.java | 70 -
.../org/apache/storm/mqtt/spout/MqttSpout.java | 270 ----
.../storm/mqtt/ssl/DefaultKeyStoreLoader.java | 92 --
.../org/apache/storm/mqtt/ssl/KeyStoreLoader.java | 34 -
.../storm/mqtt/trident/MqttPublishFunction.java | 78 -
.../storm/mqtt/StormMqttIntegrationTest.java | 143 --
external/storm-opentsdb/README.md | 76 -
external/storm-opentsdb/pom.xml | 114 --
.../storm/opentsdb/OpenTsdbMetricDatapoint.java | 134 --
.../bolt/ITupleOpenTsdbDatapointMapper.java | 39 -
.../apache/storm/opentsdb/bolt/OpenTsdbBolt.java | 188 ---
.../bolt/TupleOpenTsdbDatapointMapper.java | 135 --
.../storm/opentsdb/client/ClientResponse.java | 200 ---
.../storm/opentsdb/client/OpenTsdbClient.java | 155 --
.../storm/opentsdb/trident/OpenTsdbState.java | 92 --
.../opentsdb/trident/OpenTsdbStateFactory.java | 52 -
.../opentsdb/trident/OpenTsdbStateUpdater.java | 37 -
external/storm-pmml/README.md | 61 -
external/storm-pmml/pom.xml | 103 --
.../org/apache/storm/pmml/PMMLPredictorBolt.java | 106 --
.../org/apache/storm/pmml/model/ModelOutputs.java | 47 -
.../storm/pmml/model/jpmml/JpmmlModelOutputs.java | 156 --
.../org/apache/storm/pmml/runner/ModelRunner.java | 39 -
.../storm/pmml/runner/ModelRunnerFactory.java | 25 -
.../apache/storm/pmml/runner/PmmlModelRunner.java | 56 -
.../storm/pmml/runner/jpmml/JPmmlModelRunner.java | 156 --
.../storm/pmml/runner/jpmml/JpmmlFactory.java | 229 ---
external/storm-redis/pom.xml | 4 +-
.../state/RedisKeyValueStateIteratorTest.java | 34 +-
.../state/RedisKeyValueStateProviderTest.java | 6 +-
.../storm/redis/state/RedisKeyValueStateTest.java | 114 +-
external/storm-rocketmq/README.md | 150 --
external/storm-rocketmq/pom.xml | 90 --
.../storm/rocketmq/ConsumerBatchMessage.java | 65 -
.../rocketmq/DefaultMessageBodySerializer.java | 38 -
.../storm/rocketmq/MessageBodySerializer.java | 28 -
.../org/apache/storm/rocketmq/RocketMqConfig.java | 178 ---
.../org/apache/storm/rocketmq/RocketMqUtils.java | 80 -
.../org/apache/storm/rocketmq/SpoutConfig.java | 29 -
.../apache/storm/rocketmq/bolt/RocketMqBolt.java | 216 ---
.../mapper/FieldNameBasedTupleToMessageMapper.java | 70 -
.../common/mapper/TupleToMessageMapper.java | 32 -
.../common/selector/DefaultTopicSelector.java | 45 -
.../selector/FieldNameBasedTopicSelector.java | 70 -
.../rocketmq/common/selector/TopicSelector.java | 29 -
.../apache/storm/rocketmq/spout/RocketMqSpout.java | 228 ---
.../rocketmq/spout/scheme/KeyValueScheme.java | 27 -
.../spout/scheme/StringKeyValueScheme.java | 40 -
.../storm/rocketmq/spout/scheme/StringScheme.java | 56 -
.../rocketmq/trident/state/RocketMqState.java | 132 --
.../trident/state/RocketMqStateFactory.java | 43 -
.../trident/state/RocketMqStateUpdater.java | 35 -
.../rocketmq/DefaultMessageBodySerializerTest.java | 36 -
.../java/org/apache/storm/rocketmq/TestUtils.java | 45 -
.../storm/rocketmq/bolt/RocketMqBoltTest.java | 67 -
.../FieldNameBasedTupleToMessageMapperTest.java | 36 -
.../common/selector/DefaultTopicSelectorTest.java | 41 -
.../selector/FieldNameBasedTopicSelectorTest.java | 40 -
.../storm/rocketmq/spout/RocketMqSpoutTest.java | 87 --
.../spout/scheme/StringKeyValueSchemeTest.java | 63 -
external/storm-solr/README.md | 224 ---
external/storm-solr/pom.xml | 143 --
.../org/apache/storm/solr/bolt/SolrUpdateBolt.java | 165 ---
.../apache/storm/solr/config/CountBasedCommit.java | 53 -
.../storm/solr/config/SolrCommitStrategy.java | 24 -
.../org/apache/storm/solr/config/SolrConfig.java | 67 -
.../apache/storm/solr/mapper/SolrFieldsMapper.java | 179 ---
.../apache/storm/solr/mapper/SolrJsonMapper.java | 151 --
.../org/apache/storm/solr/mapper/SolrMapper.java | 28 -
.../storm/solr/mapper/SolrMapperException.java | 18 -
.../org/apache/storm/solr/schema/CopyField.java | 44 -
.../java/org/apache/storm/solr/schema/Field.java | 44 -
.../org/apache/storm/solr/schema/FieldType.java | 56 -
.../java/org/apache/storm/solr/schema/Schema.java | 110 --
.../storm/solr/schema/SolrFieldTypeFinder.java | 187 ---
.../solr/schema/builder/RestJsonSchemaBuilder.java | 70 -
.../schema/builder/RestJsonSchemaBuilderV2.java | 117 --
.../storm/solr/schema/builder/SchemaBuilder.java | 23 -
.../org/apache/storm/solr/trident/SolrState.java | 66 -
.../storm/solr/trident/SolrStateFactory.java | 37 -
.../org/apache/storm/solr/trident/SolrUpdater.java | 26 -
flux/README.md | 6 +-
flux/flux-core/pom.xml | 7 +-
.../src/main/java/org/apache/storm/flux/Flux.java | 6 +
.../java/org/apache/storm/flux/FluxBuilder.java | 17 +
.../org/apache/storm/flux/model/TopologyDef.java | 43 +
.../model/{BoltDef.java => WorkerHookDef.java} | 4 +-
.../org/apache/storm/flux/parser/FluxParser.java | 3 +-
.../org/apache/storm/flux/FluxBuilderTest.java | 7 +-
.../org/apache/storm/flux/IntegrationTest.java | 2 +-
.../test/java/org/apache/storm/flux/TCKTest.java | 67 +-
.../flux/multilang/MultilangEnvironmentTest.java | 20 +-
.../src/test/resources/configs/bad_hbase.yaml | 2 +-
.../src/test/resources/configs/bad_shell_test.yaml | 2 +-
.../src/test/resources/configs/kafka_test.yaml | 2 +-
.../src/test/resources/configs/shell_test.yaml | 2 +-
.../test/resources/configs/substitution-test.yaml | 2 +-
...d_static_factory_test.yaml => worker_hook.yaml} | 21 +-
flux/flux-examples/pom.xml | 2 +-
.../src/main/resources/kafka_spout.yaml | 2 +-
.../src/main/resources/multilang.yaml | 2 +-
flux/flux-wrappers/pom.xml | 2 +-
.../storm/flux/wrappers/bolts/FluxShellBolt.java | 8 +-
.../storm/flux/wrappers/spouts/FluxShellSpout.java | 8 +-
flux/pom.xml | 4 +-
integration-test/pom.xml | 2 +-
integration-test/run-it.sh | 8 +-
.../test/java/org/apache/storm/st/DemoTest.java | 15 +-
.../storm/st/tests/window/SlidingWindowTest.java | 25 +-
.../storm/st/tests/window/TumblingWindowTest.java | 16 +-
.../storm/st/tests/window/WindowVerifier.java | 19 +-
.../java/org/apache/storm/st/utils/AssertUtil.java | 21 +-
.../org/apache/storm/st/wrapper/StormCluster.java | 20 +-
.../java/org/apache/storm/st/wrapper/TopoWrap.java | 21 +-
pom.xml | 783 +++++-----
sql/pom.xml | 3 +-
sql/storm-sql-core/pom.xml | 55 +-
.../test/org/apache/storm/sql/TestStormSql.java | 35 +-
.../backends/streams/TestPlanCompiler.java | 14 +-
.../org/apache/storm/sql/parser/TestSqlParser.java | 8 +-
sql/storm-sql-external/storm-sql-hdfs/pom.xml | 43 +-
.../sql/hdfs/TestHdfsDataSourcesProvider.java | 18 +-
sql/storm-sql-external/storm-sql-kafka/pom.xml | 4 +-
.../sql/kafka/TestKafkaDataSourcesProvider.java | 10 +-
sql/storm-sql-external/storm-sql-mongodb/pom.xml | 93 --
.../sql/mongodb/MongoDataSourcesProvider.java | 125 --
...rg.apache.storm.sql.runtime.DataSourcesProvider | 16 -
.../sql/mongodb/TestMongoDataSourcesProvider.java | 55 -
sql/storm-sql-external/storm-sql-redis/pom.xml | 4 +-
.../sql/redis/TestRedisDataSourcesProvider.java | 14 +-
sql/storm-sql-runtime/pom.xml | 14 +-
.../org/apache/storm/sql/TestAvroSerializer.java | 4 +-
.../org/apache/storm/sql/TestCsvSerializer.java | 4 +-
.../apache/storm/sql/TestJsonRepresentation.java | 6 +-
.../org/apache/storm/sql/TestTsvSerializer.java | 4 +-
.../maven-shade-clojure-transformer/pom.xml | 2 +-
storm-buildtools/storm-maven-plugins/pom.xml | 4 +-
storm-checkstyle/pom.xml | 2 +-
storm-client/pom.xml | 10 +-
storm-client/src/jvm/org/apache/storm/Config.java | 66 +-
.../src/jvm/org/apache/storm/ILocalCluster.java | 4 +-
.../src/jvm/org/apache/storm/StormSubmitter.java | 2 +-
.../src/jvm/org/apache/storm/StormTimer.java | 4 +-
storm-client/src/jvm/org/apache/storm/Thrift.java | 2 +-
.../jvm/org/apache/storm/blobstore/BlobStore.java | 1 -
.../org/apache/storm/cluster/IStateStorage.java | 1 -
.../apache/storm/cluster/IStormClusterState.java | 27 +-
.../jvm/org/apache/storm/daemon/StormCommon.java | 2 +-
.../apache/storm/daemon/worker/WorkerState.java | 25 +-
.../dependency/DependencyPropertiesParser.java | 4 +-
.../src/jvm/org/apache/storm/drpc/DRPCSpout.java | 2 +-
.../jvm/org/apache/storm/drpc/ReturnResults.java | 4 +-
.../jvm/org/apache/storm/executor/Executor.java | 4 +-
.../jvm/org/apache/storm/hooks/BaseWorkerHook.java | 11 -
.../jvm/org/apache/storm/hooks/IWorkerHook.java | 19 +-
.../jvm/org/apache/storm/metric/api/IMetric.java | 7 +-
.../apache/storm/metric/api/MultiCountMetric.java | 18 +-
.../storm/metric/api/MultiReducedMetric.java | 24 +-
.../storm/metric/api/rpc/CountShellMetric.java | 8 +-
.../org/apache/storm/metric/cgroup/CGroupCpu.java | 3 +-
.../org/apache/storm/multilang/JsonSerializer.java | 6 +-
.../storm/security/auth/SimpleTransportPlugin.java | 3 +-
.../auth/kerberos/KerberosSaslTransportPlugin.java | 3 +-
.../security/auth/kerberos/NoOpTTrasport.java | 2 +-
.../serialization/BlowfishTupleSerializer.java | 4 +-
.../storm/serialization/KryoTupleSerializer.java | 2 +-
.../storm/serialization/KryoValuesSerializer.java | 4 +-
.../storm/serialization/SerializationFactory.java | 10 +-
.../serialization/types/ArrayListSerializer.java | 6 +-
.../serialization/types/HashMapSerializer.java | 6 +-
.../serialization/types/HashSetSerializer.java | 6 +-
.../types/ListDelegateSerializer.java | 4 +-
.../apache/storm/state/DefaultStateSerializer.java | 9 +-
.../src/jvm/org/apache/storm/streams/Pair.java | 3 -
.../jvm/org/apache/storm/streams/PairStream.java | 20 -
.../org/apache/storm/streams/StreamBuilder.java | 6 -
.../streams/operations/CombinerAggregator.java | 6 -
.../storm/streams/operations/StateUpdater.java | 5 -
.../processors/ChainedProcessorContext.java | 6 +-
.../processors/EmittingProcessorContext.java | 6 +-
.../processors/ForwardingProcessorContext.java | 6 +-
.../storm/streams/processors/ProcessorContext.java | 10 +-
.../apache/storm/task/GeneralTopologyContext.java | 6 +-
.../src/jvm/org/apache/storm/task/ShellBolt.java | 2 +-
.../jvm/org/apache/storm/task/TopologyContext.java | 28 +-
.../apache/storm/task/WorkerTopologyContext.java | 8 +
.../org/apache/storm/task/WorkerUserContext.java | 54 +
.../storm/topology/ConfigurableTopology.java | 3 +-
.../org/apache/storm/topology/TopologyBuilder.java | 5 +-
.../src/jvm/org/apache/storm/trident/Stream.java | 2 -
.../storm/trident/drpc/ReturnResultsReducer.java | 4 +-
.../storm/trident/operation/ITridentResource.java | 3 +-
.../state/JSONNonTransactionalSerializer.java | 17 +-
.../storm/trident/state/JSONOpaqueSerializer.java | 18 +-
.../trident/state/JSONTransactionalSerializer.java | 18 +-
.../apache/storm/trident/testing/TuplifyArgs.java | 4 +-
.../trident/topology/state/TransactionalState.java | 4 +-
.../trident/windowing/WindowKryoSerializer.java | 4 +-
.../jvm/org/apache/storm/utils/CuratorUtils.java | 27 +-
.../apache/storm/utils/DefaultShellLogHandler.java | 2 -
.../src/jvm/org/apache/storm/utils/LocalState.java | 47 +-
.../src/jvm/org/apache/storm/utils/ShellUtils.java | 11 +-
.../src/jvm/org/apache/storm/utils/Utils.java | 26 +-
.../jvm/org/apache/storm/utils/VersionInfo.java | 12 +-
.../jvm/org/apache/storm/utils/VersionedStore.java | 2 +-
.../storm/PaceMakerStateStorageFactoryTest.java | 64 +-
.../jvm/org/apache/storm/TestConfigValidate.java | 421 ++----
.../jvm/org/apache/storm/TestStormSubmitter.java | 12 +-
.../test/jvm/org/apache/storm/TestStormTimer.java | 226 +++
.../assignments/LocalAssignmentsBackendTest.java | 25 +-
.../storm/blobstore/ClientBlobStoreTest.java | 72 +-
.../jvm/org/apache/storm/bolt/TestJoinBolt.java | 27 +-
.../org/apache/storm/cluster/DaemonTypeTest.java | 6 +-
.../storm/cluster/StormClusterStateImplTest.java | 10 +-
.../daemon/metrics/ClientMetricsUtilsTest.java | 6 +-
.../daemon/worker/BackPressureTrackerTest.java | 4 +-
.../storm/daemon/worker/LogConfigManagerTest.java | 62 +-
.../daemon/worker/TestUtilsForWorkerState.java | 124 ++
.../storm/daemon/worker/WorkerStateTest.java | 110 ++
.../org/apache/storm/daemon/worker/WorkerTest.java | 8 +-
.../dependency/DependencyPropertiesParserTest.java | 25 +-
.../storm/dependency/DependencyUploaderTest.java | 159 +-
.../ExecutorTransferMultiThreadingTest.java | 54 +-
.../storm/executor/error/ReportErrorTest.java | 15 +-
.../grouping/LoadAwareShuffleGroupingTest.java | 111 +-
.../apache/storm/grouping/ShuffleGroupingTest.java | 53 +-
.../BalancedTargetSelectorTest.java | 8 +-
.../partialKeyGrouping/PartialKeyGroupingTest.java | 6 +-
.../RandomTwoTaskAssignmentCreatorTest.java | 6 +-
.../DeserializingConnectionCallbackTest.java | 16 +-
.../metric/filter/FilterByMetricNameTest.java | 23 +-
.../storm/metric/internal/CountStatTest.java | 17 +-
.../storm/metric/internal/LatencyStatTest.java | 69 +-
.../storm/metric/internal/RateTrackerTest.java | 30 +-
.../storm/metric/util/DataPointExpanderTest.java | 7 +-
.../storm/metrics2/RollingAverageGaugeTest.java | 19 +-
.../apache/storm/security/auth/AutoSSLTest.java | 32 +-
.../storm/security/auth/ClientAuthUtilsTest.java | 84 +-
.../apache/storm/security/auth/ReqContextTest.java | 33 +-
.../security/auth/SaslTransportPluginTest.java | 10 +-
.../security/auth/ShellBasedGroupsMappingTest.java | 14 +-
.../storm/security/auth/ThriftClientTest.java | 34 +-
.../authorizer/DRPCSimpleACLAuthorizerTest.java | 99 +-
.../auth/authorizer/SimpleACLAuthorizerTest.java | 471 +++---
.../serialization/BlowfishTupleSerializerTest.java | 22 +-
.../GzipBridgeThriftSerializationDelegateTest.java | 14 +-
.../serialization/SerializationFactoryTest.java | 22 +-
.../ThriftBridgeSerializationDelegateTest.java | 16 +-
.../apache/storm/spout/CheckpointSpoutTest.java | 32 +-
.../storm/state/BaseBinaryStateIteratorTest.java | 16 +-
.../storm/state/DefaultStateSerializerTest.java | 18 +-
.../storm/state/InMemoryKeyValueStateTest.java | 23 +-
.../apache/storm/streams/ProcessorBoltTest.java | 18 +-
.../storm/streams/StatefulProcessorBoltTest.java | 14 +-
.../apache/storm/streams/StreamBuilderTest.java | 37 +-
.../storm/streams/WindowedProcessorBoltTest.java | 8 +-
.../processors/CoGroupByKeyProcessorTest.java | 26 +-
.../streams/processors/JoinProcessorTest.java | 26 +-
.../org/apache/storm/testing/PerformanceTest.java | 2 +-
.../PersistentWindowedBoltExecutorTest.java | 111 +-
.../topology/SimpleWindowPartitionCacheTest.java | 126 +-
.../storm/topology/StatefulBoltExecutorTest.java | 50 +-
.../topology/StatefulWindowedBoltExecutorTest.java | 22 +-
.../apache/storm/topology/TopologyBuilderTest.java | 34 +-
.../storm/topology/WindowedBoltExecutorTest.java | 41 +-
.../apache/storm/trident/TestTridentTopology.java | 7 +-
.../apache/storm/trident/TridentWindowingTest.java | 36 +-
.../jvm/org/apache/storm/tuple/FieldsTest.java | 80 +-
.../org/apache/storm/utils/ConfigUtilsTest.java | 68 +-
.../org/apache/storm/utils/CuratorUtilsTest.java | 60 +-
.../storm/utils/DefaultShellLogHandlerTest.java | 11 +-
.../storm/utils/JCQueueBackpressureTest.java | 29 +-
.../jvm/org/apache/storm/utils/JCQueueTest.java | 25 +-
.../storm/utils/ShellBoltMessageQueueTest.java | 30 +-
.../jvm/org/apache/storm/utils/ShellUtilsTest.java | 20 +-
.../org/apache/storm/utils/SimpleVersionTest.java | 29 +-
.../StormBoundedExponentialBackoffRetryTest.java | 45 +-
.../storm/utils/ThriftTopologyUtilsTest.java | 61 +-
.../test/jvm/org/apache/storm/utils/TimeTest.java | 58 +-
.../test/jvm/org/apache/storm/utils/UtilsTest.java | 82 +-
.../windowing/WaterMarkEventGeneratorTest.java | 26 +-
.../apache/storm/windowing/WindowManagerTest.java | 113 +-
.../windowing/persistence/WindowStateTest.java | 89 +-
storm-client/test/py/test_storm_cli.py | 4 +-
storm-clojure-test/pom.xml | 2 +-
.../src/clj/org/apache/storm/testing.clj | 2 +-
storm-clojure/pom.xml | 24 +-
storm-clojure/src/clj/org/apache/storm/thrift.clj | 2 +-
storm-core/pom.xml | 43 +-
.../src/jvm/org/apache/storm/command/Activate.java | 10 +-
.../org/apache/storm/command/AdminCommands.java | 19 +-
.../org/apache/storm/command/BasicDrpcClient.java | 2 +-
.../jvm/org/apache/storm/command/Blobstore.java | 113 +-
.../src/jvm/org/apache/storm/command/CLI.java | 2 +-
.../jvm/org/apache/storm/command/Deactivate.java | 10 +-
.../jvm/org/apache/storm/command/GetErrors.java | 3 +-
.../jvm/org/apache/storm/command/Heartbeats.java | 4 +-
.../jvm/org/apache/storm/command/KillTopology.java | 36 +-
.../org/apache/storm/command/ListTopologies.java | 42 +-
.../src/jvm/org/apache/storm/command/Monitor.java | 8 +-
.../jvm/org/apache/storm/command/Rebalance.java | 14 +-
.../jvm/org/apache/storm/command/SetLogLevel.java | 16 +-
.../apache/storm/command/UploadCredentials.java | 3 +-
.../org/apache/storm/utils/TopologySpoutLag.java | 8 +-
.../test/clj/org/apache/storm/metrics_test.clj | 4 +-
.../test/clj/org/apache/storm/nimbus_test.clj | 34 +-
.../storm/security/auth/nimbus_auth_test.clj | 6 +-
.../clj/org/apache/storm/trident/state_test.clj | 4 +-
.../test/jvm/org/apache/storm/SubmitterTest.java | 4 +-
.../org/apache/storm/command/RebalanceTest.java | 22 +-
.../org/apache/storm/command/SetLogLevelTest.java | 22 +-
.../test/jvm/org/apache/storm/command/TestCLI.java | 15 +-
.../storm/integration/AckTrackingFeeder.java | 2 +-
.../org/apache/storm/integration/TestingTest.java | 2 +-
.../storm/integration/TopologyIntegrationTest.java | 132 +-
.../storm/messaging/NettyIntegrationTest.java | 10 +-
.../apache/storm/messaging/netty/NettyTest.java | 14 +-
.../storm/serialization/SerializationTest.java | 30 +-
.../jvm/org/apache/storm/stats/TestStatsUtil.java | 91 +-
storm-dist/binary/final-package/pom.xml | 2 +-
storm-dist/binary/pom.xml | 2 +-
storm-dist/binary/storm-autocreds-bin/pom.xml | 2 +-
storm-dist/binary/storm-client-bin/pom.xml | 2 +-
storm-dist/binary/storm-kafka-monitor-bin/pom.xml | 2 +-
storm-dist/binary/storm-sql-core-bin/pom.xml | 2 +-
storm-dist/binary/storm-sql-runtime-bin/pom.xml | 2 +-
storm-dist/binary/storm-submit-tools-bin/pom.xml | 2 +-
storm-dist/binary/storm-webapp-bin/pom.xml | 2 +-
storm-dist/source/pom.xml | 2 +-
storm-multilang/javascript/pom.xml | 2 +-
storm-multilang/python/pom.xml | 2 +-
.../python/src/main/resources/resources/storm.py | 36 +-
storm-multilang/ruby/pom.xml | 2 +-
storm-server/pom.xml | 16 +-
.../main/java/org/apache/storm/DaemonConfig.java | 6 +
.../main/java/org/apache/storm/LocalCluster.java | 4 +-
.../container/oci/RuncLibContainerManager.java | 7 +-
.../org/apache/storm/daemon/nimbus/Nimbus.java | 67 +-
.../org/apache/storm/localizer/AsyncLocalizer.java | 8 +-
.../apache/storm/localizer/LocalizedResource.java | 11 +-
.../apache/storm/localizer/LocallyCachedBlob.java | 69 +-
.../apache/storm/metric/timed/TimerDecorated.java | 2 +-
.../storm/metricstore/MetricStoreConfig.java | 10 +-
.../storm/metricstore/rocksdb/RocksDbStore.java | 2 +-
.../metricstore/rocksdb/StringMetadataCache.java | 8 +-
.../nimbus/AssignmentDistributionService.java | 1 -
.../storm/nimbus/LeaderListenerCallback.java | 3 +-
.../TimeOutWorkerHeartbeatsRecoveryStrategy.java | 8 +-
.../storm/scheduler/resource/ResourceUtils.java | 6 +-
.../normalization/NormalizedResourceRequest.java | 6 +-
.../scheduling/BaseResourceAwareStrategy.java | 33 +-
.../scheduling/ConstraintSolverConfig.java | 1 -
.../strategies/scheduling/ObjectResourcesItem.java | 7 +-
.../RoundRobinResourceAwareStrategy.java | 187 +++
.../scheduling/SchedulingSearcherState.java | 48 +-
.../strategies/scheduling/sorter/NodeSorter.java | 16 +-
.../scheduling/sorter/NodeSorterHostProximity.java | 21 +-
.../scheduler/utils/ArtifactoryConfigLoader.java | 19 +-
.../main/java/org/apache/storm/utils/EnumUtil.java | 2 -
.../java/org/apache/storm/utils/ServerUtils.java | 15 +-
.../src/test/java/org/apache/storm/AssertLoop.java | 2 +-
.../java/org/apache/storm/DaemonConfigTest.java | 44 +-
.../test/java/org/apache/storm/LocalStateTest.java | 25 +-
.../test/java/org/apache/storm/MessagingTest.java | 9 +-
.../test/java/org/apache/storm/PacemakerTest.java | 137 +-
.../test/java/org/apache/storm/TestCgroups.java | 49 +-
.../org/apache/storm/TestDaemonConfigValidate.java | 50 +-
.../test/java/org/apache/storm/TestRebalance.java | 146 +-
.../test/java/org/apache/storm/TestingTest.java | 14 +-
.../test/java/org/apache/storm/TickTupleTest.java | 21 +-
.../apache/storm/blobstore/BlobStoreUtilsTest.java | 12 +-
.../LocalFsBlobStoreSynchronizerTest.java | 71 +-
.../storm/blobstore/LocalFsBlobStoreTest.java | 58 +-
.../container/docker/DockerExecCommandTest.java | 8 +-
.../container/docker/DockerInspectCommandTest.java | 8 +-
.../container/docker/DockerPsCommandTest.java | 8 +-
.../container/docker/DockerRmCommandTest.java | 8 +-
.../container/docker/DockerRunCommandTest.java | 8 +-
.../container/docker/DockerStopCommandTest.java | 8 +-
.../container/docker/DockerWaitCommandTest.java | 8 +-
.../apache/storm/container/oci/OciUtilsTest.java | 76 +-
.../org/apache/storm/daemon/drpc/DRPCTest.java | 28 +-
.../storm/daemon/metrics/MetricsUtilsTest.java | 8 +-
.../org/apache/storm/daemon/nimbus/NimbusTest.java | 45 +-
.../daemon/supervisor/BasicContainerTest.java | 37 +-
.../storm/daemon/supervisor/ContainerTest.java | 37 +-
.../apache/storm/daemon/supervisor/SlotTest.java | 105 +-
.../apache/storm/localizer/AsyncLocalizerTest.java | 395 ++---
.../LocalizedResourceRetentionSetTest.java | 24 +-
.../storm/localizer/LocallyCachedBlobTest.java | 40 +-
.../metric/ClusterMetricsConsumerExecutorTest.java | 28 +-
.../storm/metricstore/rocksdb/RocksDbKeyTest.java | 36 +-
.../metricstore/rocksdb/RocksDbStoreTest.java | 150 +-
.../metricstore/rocksdb/RocksDbValueTest.java | 43 +-
.../rocksdb/StringMetadataCacheTest.java | 57 +-
.../org/apache/storm/nimbus/LocalNimbusTest.java | 11 +-
.../org/apache/storm/scheduler/ClusterTest.java | 16 +-
.../blacklist/TestBlacklistScheduler.java | 146 +-
.../resource/TestResourceAwareScheduler.java | 853 +++++------
.../apache/storm/scheduler/resource/TestUser.java | 70 +-
.../TestUtilsForResourceAwareScheduler.java | 68 +-
.../normalization/NormalizedResourceOfferTest.java | 9 +-
.../NormalizedResourceRequestTest.java | 14 +-
.../normalization/NormalizedResourcesRule.java | 49 -
.../normalization/NormalizedResourcesTest.java | 66 +-
.../normalization/ResourceMapArrayBridgeTest.java | 4 +-
.../eviction/TestDefaultEvictionStrategy.java | 427 +++---
.../TestFIFOSchedulingPriorityStrategy.java | 121 +-
...ricResourceAwareSchedulingPriorityStrategy.java | 214 +--
.../scheduling/TestBackwardCompatibility.java | 435 ------
.../scheduling/TestConstraintSolverStrategy.java | 180 +--
.../TestDefaultResourceAwareStrategy.java | 1551 ++++++++++----------
.../TestGenericResourceAwareStrategy.java | 986 +++++++------
.../strategies/scheduling/TestLargeCluster.java | 125 +-
.../TestRoundRobinNodeSorterHostIsolation.java | 265 ++++
.../scheduling/TestTopologyAnonymizerUtils.java | 19 +-
.../sorter/TestNodeSorterHostProximity.java | 120 +-
... => TestRoundRobinNodeSorterHostProximity.java} | 280 ++--
.../utils/ArtifactoryConfigLoaderTest.java | 130 +-
.../scheduler/utils/FileConfigLoaderTest.java | 30 +-
.../org/apache/storm/security/auth/AuthTest.java | 58 +-
.../auth/DefaultHttpCredentialsPluginTest.java | 28 +-
.../storm/security/auth/ServerAuthUtilsTest.java | 15 +-
.../security/auth/workertoken/WorkerTokenTest.java | 16 +-
.../apache/storm/utils/EquivalenceUtilsTest.java | 14 +-
.../org/apache/storm/utils/ServerUtilsTest.java | 33 +-
.../utils/ZookeeperServerCnxnFactoryTest.java | 14 +-
storm-shaded-deps/pom.xml | 79 +-
storm-submit-tools/pom.xml | 6 +-
.../submit/command/DependencyResolverMain.java | 4 +-
.../storm/submit/dependency/AetherUtilsTest.java | 12 +-
.../submit/dependency/DependencyResolverTest.java | 18 +-
storm-webapp/pom.xml | 18 +-
.../common/AuthorizationExceptionMapper.java | 4 -
.../daemon/drpc/webapp/DRPCExceptionMapper.java | 3 +-
.../handler/LogviewerLogDownloadHandler.java | 5 +-
.../logviewer/handler/LogviewerLogPageHandler.java | 12 +-
.../handler/LogviewerLogSearchHandler.java | 13 +-
.../logviewer/handler/LogviewerProfileHandler.java | 1 -
.../daemon/logviewer/utils/DirectoryCleaner.java | 1 +
.../storm/daemon/logviewer/utils/LogCleaner.java | 60 +-
.../logviewer/utils/LogviewerResponseBuilder.java | 2 -
.../storm/daemon/logviewer/utils/WorkerLogs.java | 9 +-
.../java/org/apache/storm/daemon/ui/UIHelpers.java | 5 +-
.../apache/storm/daemon/ui/WEB-INF/component.html | 6 +-
.../org/apache/storm/daemon/ui/WEB-INF/index.html | 7 +-
.../apache/storm/daemon/ui/WEB-INF/js/script.js | 10 +
.../org/apache/storm/daemon/ui/WEB-INF/owner.html | 9 +-
.../apache/storm/daemon/ui/WEB-INF/supervisor.html | 9 +-
.../ui/WEB-INF/templates/title-template.html | 23 +-
.../apache/storm/daemon/ui/WEB-INF/topology.html | 6 +-
.../daemon/ui/filters/AuthorizedUserFilter.java | 2 +-
.../daemon/ui/resources/StormApiResource.java | 3 +-
.../storm/daemon/utils/ListFunctionalSupport.java | 1 -
.../org/apache/storm/daemon/utils/StreamUtil.java | 1 -
.../apache/storm/daemon/drpc/DRPCServerTest.java | 13 +-
.../handler/LogviewerLogDownloadHandlerTest.java | 2 +-
.../handler/LogviewerLogPageHandlerTest.java | 8 +-
.../handler/LogviewerLogSearchHandlerTest.java | 43 +-
.../handler/LogviewerProfileHandlerTest.java | 2 +-
.../logviewer/testsupport/ArgumentsVerifier.java | 2 +-
.../daemon/logviewer/utils/LogCleanerTest.java | 46 +-
.../logviewer/utils/ResourceAuthorizerTest.java | 6 +-
.../daemon/logviewer/utils/WorkerLogsTest.java | 7 +-
.../org/apache/storm/daemon/ui/UIHelpersTest.java | 2 +-
916 files changed, 12771 insertions(+), 43874 deletions(-)
create mode 100644 .asf.yaml
create mode 100644 .github/workflows/maven.yaml
delete mode 100644 .travis.yml
create mode 100644 aws-bin/README
create mode 100755 aws-bin/aws_kafka.py
copy storm-client/src/py_license_header.txt => aws-bin/init.sh (85%)
mode change 100644 => 100755
create mode 100644 bin/test_docker_to_squash.py
create mode 100644 bin/test_storm.py
create mode 100755 dev-tools/gitact/gitact-install.sh
rename dev-tools/{travis/travis-script.sh => gitact/gitact-script.sh} (53%)
rename dev-tools/{travis => gitact}/print-errors-from-test-reports.py (100%)
rename dev-tools/{travis => gitact}/ratprint.py (76%)
rename dev-tools/{travis => gitact}/requirements.txt (100%)
rename dev-tools/{travis => gitact}/save-logs.py (74%)
mode change 100755 => 100644 dev-tools/github/__init__.py
mode change 100644 => 100755 dev-tools/release_notes.py
mode change 100644 => 100755 dev-tools/report/report.py
delete mode 100755 dev-tools/travis/travis-install.sh
delete mode 100644 docs/storm-cassandra.md
delete mode 100644 docs/storm-eventhubs.md
delete mode 100644 docs/storm-hbase.md
delete mode 100644 docs/storm-hive.md
delete mode 100644 docs/storm-kinesis.md
delete mode 100644 docs/storm-mongodb.md
delete mode 100644 docs/storm-mqtt.md
delete mode 100644 docs/storm-opentsdb.md
delete mode 100644 docs/storm-pmml.md
delete mode 100644 docs/storm-rocketmq.md
delete mode 100644 docs/storm-solr.md
delete mode 100644 examples/storm-hbase-examples/README.md
delete mode 100644 examples/storm-hbase-examples/pom.xml
delete mode 100644
examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/LookupWordCount.java
delete mode 100644
examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/PersistentWordCount.java
delete mode 100644
examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/TotalWordCounter.java
delete mode 100644
examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/WordCountClient.java
delete mode 100644
examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/WordCountValueMapper.java
delete mode 100644
examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/WordCounter.java
delete mode 100644
examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/WordSpout.java
delete mode 100644
examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/trident/PrintFunction.java
delete mode 100644
examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/trident/WordCountTrident.java
delete mode 100644 examples/storm-mongodb-examples/pom.xml
delete mode 100644
examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/InsertWordCount.java
delete mode 100644
examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/LookupWordCount.java
delete mode 100644
examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/TotalWordCounter.java
delete mode 100644
examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/UpdateWordCount.java
delete mode 100644
examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/WordCounter.java
delete mode 100644
examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/WordSpout.java
delete mode 100644
examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/trident/PrintFunction.java
delete mode 100644
examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/trident/WordCountTrident.java
delete mode 100644
examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/trident/WordCountTridentMap.java
delete mode 100644 examples/storm-mqtt-examples/pom.xml
delete mode 100644 examples/storm-mqtt-examples/src/main/flux/sample.yaml
delete mode 100644 examples/storm-mqtt-examples/src/main/flux/ssl-sample.yaml
delete mode 100644
examples/storm-mqtt-examples/src/main/java/org/apache/storm/mqtt/examples/CustomMessageMapper.java
delete mode 100644
examples/storm-mqtt-examples/src/main/java/org/apache/storm/mqtt/examples/MqttBrokerPublisher.java
delete mode 100644
examples/storm-mqtt-examples/src/main/java/org/apache/storm/mqtt/examples/package-info.java
delete mode 100644 examples/storm-mqtt-examples/src/main/resources/log4j2.xml
delete mode 100644 examples/storm-opentsdb-examples/pom.xml
delete mode 100644
examples/storm-opentsdb-examples/src/main/java/org/apache/storm/opentsdb/MetricGenBatchSpout.java
delete mode 100644
examples/storm-opentsdb-examples/src/main/java/org/apache/storm/opentsdb/MetricGenSpout.java
delete mode 100644
examples/storm-opentsdb-examples/src/main/java/org/apache/storm/opentsdb/SampleOpenTsdbBoltTopology.java
delete mode 100644
examples/storm-opentsdb-examples/src/main/java/org/apache/storm/opentsdb/SampleOpenTsdbTridentTopology.java
delete mode 100644 examples/storm-pmml-examples/pom.xml
delete mode 100644
examples/storm-pmml-examples/src/main/java/org/apache/storm/pmml/JpmmlRunnerTestTopology.java
delete mode 100644
examples/storm-pmml-examples/src/main/java/org/apache/storm/pmml/RawInputFromCSVSpout.java
delete mode 100644 examples/storm-pmml-examples/src/main/resources/Audit.50.csv
delete mode 100644
examples/storm-pmml-examples/src/main/resources/KNIME_PMML_4.1_Examples_single_audit_logreg.xml
delete mode 100644 examples/storm-pmml-examples/src/main/resources/README.md
delete mode 100644 examples/storm-rocketmq-examples/pom.xml
delete mode 100644
examples/storm-rocketmq-examples/src/main/java/org/apache/storm/rocketmq/topology/WordCountTopology.java
delete mode 100644
examples/storm-rocketmq-examples/src/main/java/org/apache/storm/rocketmq/topology/WordCounter.java
delete mode 100644
examples/storm-rocketmq-examples/src/main/java/org/apache/storm/rocketmq/trident/WordCountTrident.java
delete mode 100644 examples/storm-solr-examples/pom.xml
delete mode 100644
examples/storm-solr-examples/src/main/java/org/apache/storm/solr/spout/SolrFieldsSpout.java
delete mode 100644
examples/storm-solr-examples/src/main/java/org/apache/storm/solr/spout/SolrJsonSpout.java
delete mode 100644
examples/storm-solr-examples/src/main/java/org/apache/storm/solr/topology/SolrFieldsTopology.java
delete mode 100644
examples/storm-solr-examples/src/main/java/org/apache/storm/solr/topology/SolrJsonTopology.java
delete mode 100644
examples/storm-solr-examples/src/main/java/org/apache/storm/solr/topology/SolrTopology.java
delete mode 100644
examples/storm-solr-examples/src/main/java/org/apache/storm/solr/trident/SolrFieldsTridentTopology.java
delete mode 100644
examples/storm-solr-examples/src/main/java/org/apache/storm/solr/trident/SolrJsonTridentTopology.java
delete mode 100644
examples/storm-solr-examples/src/main/java/org/apache/storm/solr/util/TestUtil.java
delete mode 100644 external/storm-cassandra/README.md
delete mode 100644 external/storm-cassandra/pom.xml
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/AbstractExecutionResultHandler.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/BaseExecutionResultHandler.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/CassandraContext.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/DynamicStatementBuilder.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/ExecutionResultHandler.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/Murmur3StreamGrouping.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/bolt/BaseCassandraBolt.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/bolt/BatchCassandraWriterBolt.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/bolt/CassandraWriterBolt.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/bolt/GroupingBatchBuilder.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/bolt/PairBatchStatementTuples.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/bolt/PairStatementTuple.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/client/CassandraConf.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/client/ClusterFactory.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/client/SimpleClient.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/client/SimpleClientProvider.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/client/impl/DefaultClient.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/context/BaseBeanFactory.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/context/BeanFactory.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/context/WorkerCtx.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/executor/AsyncExecutor.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/executor/AsyncExecutorProvider.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/executor/AsyncResultHandler.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/executor/AsyncResultSetHandler.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/executor/ExecutionResultCollector.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/executor/impl/BatchAsyncResultHandler.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/executor/impl/SingleAsyncResultHandler.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/AyncCQLResultSetValuesMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/BaseCQLStatementTupleMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/CQLResultSetValuesMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/CQLStatementBuilder.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/CQLStatementTupleMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/Column.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/ContextQuery.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/CqlMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/ObjectMapperOperation.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/builder/BoundCQLStatementMapperBuilder.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/builder/ObjectMapperCqlStatementMapperBuilder.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/builder/SimpleCQLStatementMapperBuilder.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/impl/BatchCQLStatementTupleMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/impl/BoundCQLStatementTupleMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/impl/ObjectMapperCqlStatementMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/impl/PreparedStatementBinder.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/impl/RoutingKeyGenerator.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/impl/SimpleCQLStatementMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/selector/FieldSelector.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/CassandraBackingMap.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/CassandraMapStateFactory.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/CassandraQuery.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/CassandraState.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/CassandraStateFactory.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/CassandraStateUpdater.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/MapStateFactoryBuilder.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/NonTransactionalTupleStateMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/OpaqueTupleStateMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/SerializedStateMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/SimpleStateMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/SimpleTuple.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/StateMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/TransactionalTupleStateMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/TridentAyncCQLResultSetValuesMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/TridentResultSetValuesMapper.java
delete mode 100644
external/storm-cassandra/src/test/java/org/apache/storm/cassandra/WeatherSpout.java
delete mode 100644
external/storm-cassandra/src/test/java/org/apache/storm/cassandra/testtools/EmbeddedCassandraResource.java
delete mode 100644
external/storm-cassandra/src/test/java/org/apache/storm/cassandra/trident/MapStateTest.java
delete mode 100644
external/storm-cassandra/src/test/java/org/apache/storm/cassandra/trident/WeatherBatchSpout.java
delete mode 100644 external/storm-cassandra/src/test/resources/cassandra.yaml
delete mode 100755 external/storm-eventhubs/README.md
delete mode 100755 external/storm-eventhubs/pom.xml
delete mode 100644
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/bolt/DefaultEventDataFormat.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/bolt/EventHubBolt.java
delete mode 100644
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/bolt/EventHubBoltConfig.java
delete mode 100644
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/bolt/IEventDataFormat.java
delete mode 100644
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/BinaryEventDataScheme.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/EventDataScheme.java
delete mode 100644
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/EventDataWrap.java
delete mode 100644
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/EventHubException.java
delete mode 100644
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/EventHubFilter.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/EventHubReceiverImpl.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/EventHubSpout.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/EventHubSpoutConfig.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/FieldConstants.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/IEventDataScheme.java
delete mode 100644
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/IEventFilter.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/IEventHubReceiver.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/IEventHubReceiverFactory.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/IPartitionCoordinator.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/IPartitionManager.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/IPartitionManagerFactory.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/IStateStore.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/MessageId.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/PartitionManager.java
delete mode 100644
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/SerializeDeserializeUtil.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/SimplePartitionManager.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/StaticPartitionCoordinator.java
delete mode 100644
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/StringEventDataScheme.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/ZookeeperStateStore.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/trident/Coordinator.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/trident/ITridentPartitionManager.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/trident/ITridentPartitionManagerFactory.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/trident/OpaqueTridentEventHubEmitter.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/trident/OpaqueTridentEventHubSpout.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/trident/Partition.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/trident/Partitions.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/trident/TransactionalTridentEventHubEmitter.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/trident/TransactionalTridentEventHubSpout.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/trident/TridentPartitionManager.java
delete mode 100755
external/storm-eventhubs/src/main/resources/config.properties
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/samples/AtMostOnceEventCount.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/samples/EventCount.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/samples/EventHubLoop.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/samples/OpaqueTridentEventCount.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/samples/TransactionalTridentEventCount.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/samples/bolt/GlobalCountBolt.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/samples/bolt/PartialCountBolt.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/spout/EventHubReceiverMock.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/spout/EventHubSpoutCallerMock.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/spout/PartitionManagerCallerMock.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/spout/SpoutOutputCollectorMock.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/spout/StateStoreMock.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/spout/TestEventData.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/spout/TestEventHubSpout.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/spout/TestPartitionManager.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/trident/TestTransactionalTridentEmitter.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/trident/TridentCollectorMock.java
delete mode 100644 external/storm-hbase/README.md
delete mode 100644 external/storm-hbase/pom.xml
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/bolt/AbstractHBaseBolt.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/bolt/HBaseBolt.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/bolt/HBaseLookupBolt.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/bolt/mapper/HBaseMapper.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/bolt/mapper/HBaseProjectionCriteria.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/bolt/mapper/HBaseValueMapper.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/bolt/mapper/SimpleHBaseMapper.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/common/ColumnList.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/common/HBaseClient.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/common/IColumn.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/common/ICounter.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/common/Utils.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/state/HBaseKeyValueState.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/state/HBaseKeyValueStateIterator.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/state/HBaseKeyValueStateProvider.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/mapper/SimpleTridentHBaseMapMapper.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/mapper/SimpleTridentHBaseMapper.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/mapper/TridentHBaseMapMapper.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/mapper/TridentHBaseMapper.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseMapState.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseQuery.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseState.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseStateFactory.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseUpdater.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/windowing/HBaseWindowsStore.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/windowing/HBaseWindowsStoreFactory.java
delete mode 100644
external/storm-hbase/src/test/java/org/apache/storm/hbase/state/HBaseClientTestUtil.java
delete mode 100644
external/storm-hbase/src/test/java/org/apache/storm/hbase/state/HBaseKeyValueStateIteratorTest.java
delete mode 100644
external/storm-hbase/src/test/java/org/apache/storm/hbase/state/HBaseKeyValueStateProviderTest.java
delete mode 100644
external/storm-hbase/src/test/java/org/apache/storm/hbase/state/HBaseKeyValueStateTest.java
copy
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/testing/{MiniDFSClusterExtension.java
=> MiniDFSClusterExtensionClassLevel.java} (72%)
delete mode 100644
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/testing/MiniDFSClusterRule.java
delete mode 100644
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/metrics/KafkaOffsetMetric.java
create mode 100644
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/metrics2/KafkaOffsetMetricManager.java
create mode 100644
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/metrics2/KafkaOffsetPartitionMetrics.java
create mode 100644
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/metrics2/KafkaOffsetTopicMetrics.java
delete mode 100644 external/storm-kinesis/README.md
delete mode 100644 external/storm-kinesis/pom.xml
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/CredentialsProviderChain.java
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/ExponentialBackoffRetrier.java
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/FailedMessageRetryHandler.java
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/KinesisConfig.java
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/KinesisConnection.java
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/KinesisConnectionInfo.java
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/KinesisMessageId.java
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/KinesisRecordsManager.java
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/KinesisSpout.java
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/RecordToTupleMapper.java
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/ZkConnection.java
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/ZkInfo.java
delete mode 100644
external/storm-kinesis/src/test/java/org/apache/storm/kinesis/spout/test/KinesisBoltTest.java
delete mode 100644
external/storm-kinesis/src/test/java/org/apache/storm/kinesis/spout/test/KinesisSpoutTopology.java
delete mode 100644
external/storm-kinesis/src/test/java/org/apache/storm/kinesis/spout/test/TestRecordToTupleMapper.java
delete mode 100644 external/storm-mongodb/README.md
delete mode 100644 external/storm-mongodb/pom.xml
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/bolt/AbstractMongoBolt.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/bolt/MongoInsertBolt.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/bolt/MongoLookupBolt.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/bolt/MongoUpdateBolt.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/common/MongoDbClient.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/common/MongoUtils.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/common/QueryFilterCreator.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/common/SimpleQueryFilterCreator.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/common/mapper/MongoLookupMapper.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/common/mapper/MongoMapper.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/common/mapper/MongoUpdateMapper.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/common/mapper/SimpleMongoLookupMapper.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/common/mapper/SimpleMongoMapper.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/common/mapper/SimpleMongoUpdateMapper.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/trident/state/MongoMapState.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/trident/state/MongoState.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/trident/state/MongoStateFactory.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/trident/state/MongoStateQuery.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/trident/state/MongoStateUpdater.java
delete mode 100644 external/storm-mqtt/README.md
delete mode 100644 external/storm-mqtt/pom.xml
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/MqttLogger.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/MqttMessage.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/MqttMessageMapper.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/MqttTupleMapper.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/bolt/MqttBolt.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/common/MqttOptions.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/common/MqttPublisher.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/common/MqttUtils.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/common/SslUtils.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/mappers/ByteArrayMessageMapper.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/mappers/StringMessageMapper.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/spout/AckableMessage.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/spout/MqttSpout.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/ssl/DefaultKeyStoreLoader.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/ssl/KeyStoreLoader.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/trident/MqttPublishFunction.java
delete mode 100644
external/storm-mqtt/src/test/java/org/apache/storm/mqtt/StormMqttIntegrationTest.java
delete mode 100644 external/storm-opentsdb/README.md
delete mode 100644 external/storm-opentsdb/pom.xml
delete mode 100644
external/storm-opentsdb/src/main/java/org/apache/storm/opentsdb/OpenTsdbMetricDatapoint.java
delete mode 100644
external/storm-opentsdb/src/main/java/org/apache/storm/opentsdb/bolt/ITupleOpenTsdbDatapointMapper.java
delete mode 100644
external/storm-opentsdb/src/main/java/org/apache/storm/opentsdb/bolt/OpenTsdbBolt.java
delete mode 100644
external/storm-opentsdb/src/main/java/org/apache/storm/opentsdb/bolt/TupleOpenTsdbDatapointMapper.java
delete mode 100644
external/storm-opentsdb/src/main/java/org/apache/storm/opentsdb/client/ClientResponse.java
delete mode 100644
external/storm-opentsdb/src/main/java/org/apache/storm/opentsdb/client/OpenTsdbClient.java
delete mode 100644
external/storm-opentsdb/src/main/java/org/apache/storm/opentsdb/trident/OpenTsdbState.java
delete mode 100644
external/storm-opentsdb/src/main/java/org/apache/storm/opentsdb/trident/OpenTsdbStateFactory.java
delete mode 100644
external/storm-opentsdb/src/main/java/org/apache/storm/opentsdb/trident/OpenTsdbStateUpdater.java
delete mode 100644 external/storm-pmml/README.md
delete mode 100644 external/storm-pmml/pom.xml
delete mode 100644
external/storm-pmml/src/main/java/org/apache/storm/pmml/PMMLPredictorBolt.java
delete mode 100644
external/storm-pmml/src/main/java/org/apache/storm/pmml/model/ModelOutputs.java
delete mode 100644
external/storm-pmml/src/main/java/org/apache/storm/pmml/model/jpmml/JpmmlModelOutputs.java
delete mode 100644
external/storm-pmml/src/main/java/org/apache/storm/pmml/runner/ModelRunner.java
delete mode 100644
external/storm-pmml/src/main/java/org/apache/storm/pmml/runner/ModelRunnerFactory.java
delete mode 100644
external/storm-pmml/src/main/java/org/apache/storm/pmml/runner/PmmlModelRunner.java
delete mode 100644
external/storm-pmml/src/main/java/org/apache/storm/pmml/runner/jpmml/JPmmlModelRunner.java
delete mode 100644
external/storm-pmml/src/main/java/org/apache/storm/pmml/runner/jpmml/JpmmlFactory.java
delete mode 100644 external/storm-rocketmq/README.md
delete mode 100644 external/storm-rocketmq/pom.xml
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/ConsumerBatchMessage.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/DefaultMessageBodySerializer.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/MessageBodySerializer.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/RocketMqConfig.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/RocketMqUtils.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/SpoutConfig.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/bolt/RocketMqBolt.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/common/mapper/FieldNameBasedTupleToMessageMapper.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/common/mapper/TupleToMessageMapper.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/common/selector/DefaultTopicSelector.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/common/selector/FieldNameBasedTopicSelector.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/common/selector/TopicSelector.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/spout/RocketMqSpout.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/spout/scheme/KeyValueScheme.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/spout/scheme/StringKeyValueScheme.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/spout/scheme/StringScheme.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/trident/state/RocketMqState.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/trident/state/RocketMqStateFactory.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/trident/state/RocketMqStateUpdater.java
delete mode 100644
external/storm-rocketmq/src/test/java/org/apache/storm/rocketmq/DefaultMessageBodySerializerTest.java
delete mode 100644
external/storm-rocketmq/src/test/java/org/apache/storm/rocketmq/TestUtils.java
delete mode 100644
external/storm-rocketmq/src/test/java/org/apache/storm/rocketmq/bolt/RocketMqBoltTest.java
delete mode 100644
external/storm-rocketmq/src/test/java/org/apache/storm/rocketmq/common/mapper/FieldNameBasedTupleToMessageMapperTest.java
delete mode 100644
external/storm-rocketmq/src/test/java/org/apache/storm/rocketmq/common/selector/DefaultTopicSelectorTest.java
delete mode 100644
external/storm-rocketmq/src/test/java/org/apache/storm/rocketmq/common/selector/FieldNameBasedTopicSelectorTest.java
delete mode 100644
external/storm-rocketmq/src/test/java/org/apache/storm/rocketmq/spout/RocketMqSpoutTest.java
delete mode 100644
external/storm-rocketmq/src/test/java/org/apache/storm/rocketmq/spout/scheme/StringKeyValueSchemeTest.java
delete mode 100644 external/storm-solr/README.md
delete mode 100644 external/storm-solr/pom.xml
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/bolt/SolrUpdateBolt.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/config/CountBasedCommit.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/config/SolrCommitStrategy.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/config/SolrConfig.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/mapper/SolrFieldsMapper.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/mapper/SolrJsonMapper.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/mapper/SolrMapper.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/mapper/SolrMapperException.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/schema/CopyField.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/schema/Field.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/schema/FieldType.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/schema/Schema.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/schema/SolrFieldTypeFinder.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/schema/builder/RestJsonSchemaBuilder.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/schema/builder/RestJsonSchemaBuilderV2.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/schema/builder/SchemaBuilder.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/trident/SolrState.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/trident/SolrStateFactory.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/trident/SolrUpdater.java
copy flux/flux-core/src/main/java/org/apache/storm/flux/model/{BoltDef.java =>
WorkerHookDef.java} (90%)
copy flux/flux-core/src/test/resources/configs/{bad_static_factory_test.yaml
=> worker_hook.yaml} (84%)
delete mode 100644 sql/storm-sql-external/storm-sql-mongodb/pom.xml
delete mode 100644
sql/storm-sql-external/storm-sql-mongodb/src/jvm/org/apache/storm/sql/mongodb/MongoDataSourcesProvider.java
delete mode 100644
sql/storm-sql-external/storm-sql-mongodb/src/resources/META-INF/services/org.apache.storm.sql.runtime.DataSourcesProvider
delete mode 100644
sql/storm-sql-external/storm-sql-mongodb/src/test/org/apache/storm/sql/mongodb/TestMongoDataSourcesProvider.java
create mode 100644
storm-client/src/jvm/org/apache/storm/task/WorkerUserContext.java
create mode 100644 storm-client/test/jvm/org/apache/storm/TestStormTimer.java
create mode 100644
storm-client/test/jvm/org/apache/storm/daemon/worker/TestUtilsForWorkerState.java
create mode 100644
storm-client/test/jvm/org/apache/storm/daemon/worker/WorkerStateTest.java
create mode 100644
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/RoundRobinResourceAwareStrategy.java
delete mode 100644
storm-server/src/test/java/org/apache/storm/scheduler/resource/normalization/NormalizedResourcesRule.java
delete mode 100644
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestBackwardCompatibility.java
create mode 100644
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestRoundRobinNodeSorterHostIsolation.java
copy
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/sorter/{TestNodeSorterHostProximity.java
=> TestRoundRobinNodeSorterHostProximity.java} (75%)
rename external/storm-cassandra/src/test/resources/schema.cql =>
storm-webapp/src/main/java/org/apache/storm/daemon/ui/WEB-INF/templates/title-template.html
(72%)
