Tested, no negative effects seen

twitter · Nov 19, 2013 · 27200bf · 27200bf
1 parent 74f7e81
commit 27200bf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/summingbird-storm/src/main/scala/com/twitter/summingbird/storm/StormPlatform.scala b/summingbird-storm/src/main/scala/com/twitter/summingbird/storm/StormPlatform.scala
@@ -210,7 +210,7 @@ abstract class Storm(options: Map[String, Options], transformConfig: Summingbird
     val dependenciesNames = stormDag.dependenciesOf(node).collect { case x: StormNode => stormDag.getNodeName(x) }
     // TODO: https://github.com/twitter/summingbird/issues/366
     // test localOrShuffleGrouping here. may give big wins for serialization heavy jobs.
-    dependenciesNames.foreach { declarer.shuffleGrouping(_) }
+    dependenciesNames.foreach { declarer.localOrShuffleGrouping(_) }
   }
 
   private def scheduleSpout[K](stormDag: Dag[Storm], node: StormNode)(implicit topologyBuilder: TopologyBuilder) = {