[GitHub] storm pull request #2241: STORM-2306 : Messaging subsystem redesign.

[HeartSaVioR]

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.


---