revert some unintended changes
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/9a8dfb7d Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/9a8dfb7d Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/9a8dfb7d Branch: refs/heads/1.x-branch Commit: 9a8dfb7d075eb0d0ca2fedd8df88cdb6608cb87e Parents: fa1e59f Author: P. Taylor Goetz <[email protected]> Authored: Tue Jul 11 14:54:46 2017 -0400 Committer: P. Taylor Goetz <[email protected]> Committed: Tue Jul 11 14:54:46 2017 -0400 ---------------------------------------------------------------------- .../src/jvm/org/apache/storm/starter/ExclamationTopology.java | 2 +- .../src/jvm/org/apache/storm/starter/WordCountTopology.java | 2 +- .../java/org/apache/storm/hdfs/avro/ConfluentAvroSerializer.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/9a8dfb7d/examples/storm-starter/src/jvm/org/apache/storm/starter/ExclamationTopology.java ---------------------------------------------------------------------- diff --git a/examples/storm-starter/src/jvm/org/apache/storm/starter/ExclamationTopology.java b/examples/storm-starter/src/jvm/org/apache/storm/starter/ExclamationTopology.java index 9284b52..26e0430 100644 --- a/examples/storm-starter/src/jvm/org/apache/storm/starter/ExclamationTopology.java +++ b/examples/storm-starter/src/jvm/org/apache/storm/starter/ExclamationTopology.java @@ -79,7 +79,7 @@ public class ExclamationTopology { LocalCluster cluster = new LocalCluster(); cluster.submitTopology("test", conf, builder.createTopology()); - Utils.sleep(100000); + Utils.sleep(10000); cluster.killTopology("test"); cluster.shutdown(); } http://git-wip-us.apache.org/repos/asf/storm/blob/9a8dfb7d/examples/storm-starter/src/jvm/org/apache/storm/starter/WordCountTopology.java ---------------------------------------------------------------------- diff --git a/examples/storm-starter/src/jvm/org/apache/storm/starter/WordCountTopology.java b/examples/storm-starter/src/jvm/org/apache/storm/starter/WordCountTopology.java index 0611894..e4a5711 100644 --- a/examples/storm-starter/src/jvm/org/apache/storm/starter/WordCountTopology.java +++ b/examples/storm-starter/src/jvm/org/apache/storm/starter/WordCountTopology.java @@ -98,7 +98,7 @@ public class WordCountTopology { LocalCluster cluster = new LocalCluster(); cluster.submitTopology("word-count", conf, builder.createTopology()); - Thread.sleep(60000); + Thread.sleep(10000); cluster.shutdown(); } http://git-wip-us.apache.org/repos/asf/storm/blob/9a8dfb7d/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/avro/ConfluentAvroSerializer.java ---------------------------------------------------------------------- diff --git a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/avro/ConfluentAvroSerializer.java b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/avro/ConfluentAvroSerializer.java index 087aec5..2008a3e 100644 --- a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/avro/ConfluentAvroSerializer.java +++ b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/avro/ConfluentAvroSerializer.java @@ -27,7 +27,7 @@ import java.io.IOException; import java.util.Map; /** - * This class provides a mechanism to utilize the Confluent Schema StormMetricRegistry (https://github.com/confluentinc/schema-registry) + * This class provides a mechanism to utilize the Confluent Schema Registry (https://github.com/confluentinc/schema-registry) * for Storm to (de)serialize Avro generic records across a topology. It assumes the schema registry is up and running * completely independent of Storm. */
