Github user srdo commented on a diff in the pull request:
https://github.com/apache/storm/pull/2675#discussion_r189455082
--- Diff:
examples/storm-rocketmq-examples/src/main/java/org/apache/storm/rocketmq/trident/WordCountTrident.java
---
@@ -76,19 +74,16 @@ public static StormTopology buildTopology(String
nameserverAddr, String topic){
public static void main(String[] args) throws Exception {
Config conf = new Config();
conf.setMaxSpoutPending(5);
- if (args.length == 2) {
- try (LocalCluster cluster = new LocalCluster();
- LocalTopology topo =
cluster.submitTopology("wordCounter", conf, buildTopology(args[0], args[1]));) {
- Thread.sleep(60 * 1000);
+ conf.setNumWorkers(3);
+
+ String topologyName = "wordCounter";
+ if (args.length < 2) {
+ System.out.println("Usage: WordCountTopology <nameserver addr>
<topic> [topology name]");
--- End diff --
Nit: Should be WordCountTrident
---
