You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sr...@apache.org on 2018/07/05 18:23:07 UTC

[2/2] storm git commit: Merge branch 'STORM-3142' of https://github.com/srdo/storm into asfgit-master

Merge branch 'STORM-3142' 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/db86bade
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/db86bade
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/db86bade

Branch: refs/heads/master
Commit: db86bade005494aa26e782a3be5a64cb67ed522b
Parents: 26d2f95 c14a9b5
Author: Stig Rohde Døssing <sr...@apache.org>
Authored: Thu Jul 5 20:22:38 2018 +0200
Committer: Stig Rohde Døssing <sr...@apache.org>
Committed: Thu Jul 5 20:22:38 2018 +0200

----------------------------------------------------------------------
 examples/storm-loadgen/pom.xml                  |  5 --
 examples/storm-starter/pom.xml                  |  5 --
 external/storm-elasticsearch/pom.xml            |  5 --
 external/storm-hbase/pom.xml                    |  5 --
 external/storm-jms/pom.xml                      |  6 ---
 external/storm-kafka-client/pom.xml             |  4 ++
 .../java/org/apache/storm/kafka/KafkaUnit.java  |  6 ++-
 .../apache/storm/kafka/KafkaUnitExtension.java  | 45 ++++++++++++++++
 .../org/apache/storm/kafka/KafkaUnitRule.java   | 45 ----------------
 .../storm/kafka/NullRecordTranslator.java       |  1 -
 .../kafka/spout/KafkaSpoutAbstractTest.java     | 50 ++++++++----------
 .../storm/kafka/spout/KafkaSpoutConfigTest.java | 31 +++++------
 .../storm/kafka/spout/KafkaSpoutEmitTest.java   |  8 ++-
 .../kafka/spout/KafkaSpoutNullTupleTest.java    | 12 ++---
 .../kafka/spout/KafkaSpoutReactivationTest.java | 25 +++++----
 .../kafka/spout/KafkaSpoutSingleTopicTest.java  | 55 +++++++++-----------
 ...outTopologyDeployActivateDeactivateTest.java |  9 ++--
 .../kafka/spout/MaxUncommittedOffsetTest.java   | 34 ++++++------
 .../kafka/spout/internal/OffsetManagerTest.java | 17 +++---
 external/storm-mongodb/pom.xml                  |  5 --
 external/storm-opentsdb/pom.xml                 |  5 --
 external/storm-redis/pom.xml                    |  5 --
 external/storm-rocketmq/pom.xml                 |  5 --
 pom.xml                                         | 28 +++++++---
 sql/storm-sql-core/pom.xml                      |  5 --
 sql/storm-sql-external/storm-sql-hdfs/pom.xml   |  5 --
 sql/storm-sql-external/storm-sql-kafka/pom.xml  |  5 --
 .../storm-sql-mongodb/pom.xml                   |  5 --
 sql/storm-sql-external/storm-sql-redis/pom.xml  |  5 --
 sql/storm-sql-runtime/pom.xml                   |  5 --
 storm-buildtools/storm-maven-plugins/pom.xml    |  5 --
 storm-client/pom.xml                            |  4 --
 .../jvm/org/apache/storm/testing/TmpPath.java   |  2 +-
 storm-core/pom.xml                              |  5 --
 storm-webapp/pom.xml                            |  4 --
 35 files changed, 182 insertions(+), 284 deletions(-)
----------------------------------------------------------------------