You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2018/01/22 17:41:08 UTC
[02/38] storm git commit: revert some unintended changes
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 <pt...@gmail.com>
Authored: Tue Jul 11 14:54:46 2017 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
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.
*/