[GitHub] storm pull request #2502: new PR for STORM-2306 : Messaging subsystem redesi...

[revans2]

Github user revans2 commented on a diff in the pull request:

    https://github.com/apache/storm/pull/2502#discussion_r167288058
  
    --- Diff: storm-client/src/jvm/org/apache/storm/daemon/Acker.java ---
    @@ -99,17 +100,19 @@ public void execute(Tuple input) {
                 pending.put(id, curr);
             } else if (ACKER_RESET_TIMEOUT_STREAM_ID.equals(streamId)) {
                 resetTimeout = true;
    -            if (curr != null) {
    +            if (curr == null) {
    --- End diff --
    
    Why is this change being made?


---