Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2624#discussion_r180049067
--- Diff: storm-client/src/jvm/org/apache/storm/daemon/worker/Worker.java
---
@@ -223,7 +224,7 @@ private Object loadWorker(Map<String, Object>
topologyConf, IStateStorage stateS
// This thread will send out messages destined for remote tasks
(on other workers)
- if ( ( (Long)topologyConf.get(Config.TOPOLOGY_WORKERS) ) > 1 ) {
+ if (((Long)topologyConf.get(Config.TOPOLOGY_WORKERS)) > 1) {
--- End diff --
Please rebase with latest master.
---
