Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/2241 FYI: Regarding improving LoadAwareShuffleGrouping, I spent some days and published my improvement on #2261. From my latest update, compared to current, #2261 is about 4x faster with single-thread benchmark, and 2x faster with two-threads benchmark. I need to run same benchmarks against ShuffleGrouping but I guess #2261 should be close to current ShuffleGrouping, based on fact that chooseTasks() now does the same thing which ShuffleGrouping is doing. (ShuffleGrouping in current PR is optimized for single-thread and drops thread-safety, so can't compare them directly.)
--- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---