Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2241#discussion_r158016550
--- Diff:
examples/storm-starter/src/jvm/org/apache/storm/starter/ThroughputVsLatency.java
---
@@ -356,9 +356,8 @@ public void handle(TaskInfo taskInfo,
Collection<DataPoint> dataPoints) {
TopologyBuilder builder = new TopologyBuilder();
- int numEach = 4 * parallelism;
+ int numEach = parallelism;
--- End diff --
Nice catch.---
