Hello. I have a question about the load aware shuffle grouping.

If I create a grouping like below, will I end up with a
LoadAwareShuffleGrouping by default?

topologyBuilder.setBolt("boltId", new
SomeBolt()).shuffleGrouping("otherBoltId");

I would expect this to result in a traditional ShuffleGrouping, but I think
it does not based on the following:

(1) the config option TOPOLOGY-DISABLE-LOADAWARE-MESSAGING defaults to
false.
(2) This block of code seems to create a LoadAwareShuffleGrouping
automatically if load messaging is enabled (the default).
https://github.com/revans2/incubator-storm/blob/024ff263800e4032d7b2395fbbf072e0183ebb5b/storm-core/src/clj/backtype/storm/daemon/executor.clj#L66


Is this correct? Is load aware the default behavior in Storm 1.0.x?

Reply via email to