Github user arunmahadevan commented on the issue:
https://github.com/apache/storm/pull/2639
@ptgoetz , thanks for the suggestion.
Yes, it was clear why the distributed flag was needed when it was not used
anywhere else in the code. I was hoping that the user will set the right
parallelism while consuming from topics. I can add it back.---
