Github user agresch commented on a diff in the pull request:
https://github.com/apache/storm/pull/2634#discussion_r181480542
--- Diff: storm-client/src/jvm/org/apache/storm/daemon/worker/Worker.java
---
@@ -305,8 +305,9 @@ private void setupFlushTupleTimer(final Map<String,
Object> topologyConf, final
}
private void setupBackPressureCheckTimer(final Map<String, Object>
topologyConf) {
--- End diff --
My bad. ---
