Merge branch 'STORM-2698-2' of https://github.com/srdo/storm into asfgit-master
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/352cd466 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/352cd466 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/352cd466 Branch: refs/heads/master Commit: 352cd4665287712813d5f6f2af2537769a2cbb82 Parents: 1a85763 3503dce Author: Stig Rohde Døssing <s...@apache.org> Authored: Mon Oct 9 20:39:49 2017 +0200 Committer: Stig Rohde Døssing <s...@apache.org> Committed: Mon Oct 9 20:39:49 2017 +0200 ---------------------------------------------------------------------- examples/storm-starter/pom.xml | 9 +- external/storm-cassandra/pom.xml | 8 +- external/storm-elasticsearch/pom.xml | 13 +- .../elasticsearch/bolt/EsLookupBoltTest.java | 1 - .../elasticsearch/bolt/EsPercolateBoltTest.java | 13 +- external/storm-hbase/pom.xml | 7 +- external/storm-hdfs/pom.xml | 7 +- external/storm-hive/pom.xml | 10 +- external/storm-kafka-client/pom.xml | 9 +- .../apache/storm/kafka/bolt/KafkaBoltTest.java | 9 +- .../storm/kafka/spout/KafkaSpoutCommitTest.java | 10 +- external/storm-kafka/pom.xml | 8 +- .../org/apache/storm/kafka/bolt/KafkaBolt.java | 2 +- .../apache/storm/kafka/bolt/KafkaBoltTest.java | 15 +- external/storm-mongodb/pom.xml | 7 +- external/storm-opentsdb/pom.xml | 7 +- external/storm-redis/pom.xml | 7 +- pom.xml | 18 +- sql/storm-sql-core/pom.xml | 7 +- sql/storm-sql-external/storm-sql-hdfs/pom.xml | 7 +- .../sql/hdfs/TestHdfsDataSourcesProvider.java | 140 +++++++------- sql/storm-sql-external/storm-sql-kafka/pom.xml | 7 +- .../sql/kafka/TestKafkaDataSourcesProvider.java | 136 +++++++------- .../storm-sql-mongodb/pom.xml | 7 +- .../mongodb/TestMongoDataSourcesProvider.java | 121 ++++++------ sql/storm-sql-external/storm-sql-redis/pom.xml | 7 +- .../sql/redis/TestRedisDataSourcesProvider.java | 188 ++++++++++--------- sql/storm-sql-runtime/pom.xml | 7 +- storm-client/pom.xml | 8 +- .../storm/grouping/PartialKeyGroupingTest.java | 2 +- .../PersistentWindowedBoltExecutorTest.java | 29 ++- .../topology/StatefulBoltExecutorTest.java | 39 ++-- .../windowing/persistence/WindowStateTest.java | 10 - storm-core/pom.xml | 8 +- .../test/clj/org/apache/storm/cluster_test.clj | 2 +- .../test/clj/org/apache/storm/drpc_test.clj | 14 +- storm-server/pom.xml | 6 +- .../storm/daemon/supervisor/BasicContainer.java | 2 +- .../storm/localizer/AsyncLocalizerTest.java | 13 +- storm-webapp/pom.xml | 11 +- .../handler/LogviewerLogSearchHandlerTest.java | 27 +-- .../daemon/logviewer/utils/LogCleanerTest.java | 20 +- 42 files changed, 510 insertions(+), 468 deletions(-) ----------------------------------------------------------------------
