Github user Ethanlm commented on a diff in the pull request:
https://github.com/apache/storm/pull/2641#discussion_r183399672
--- Diff:
examples/storm-perf/src/main/java/org/apache/storm/perf/LowThroughputTopo.java
---
@@ -64,7 +63,7 @@ static StormTopology getTopology(Map<String, Object>
conf) {
BoltDeclarer bd = builder.setBolt(BOLT_ID, bolt,
Helper.getInt(conf, BOLT_COUNT, 1));
bd.localOrShuffleGrouping(SPOUT_ID);
-// bd.shuffleGrouping(SPOUT_ID);
+ // bd.shuffleGrouping(SPOUT_ID);
--- End diff --
nit: space?
---
