Merge pull request #371 from twitter/feature/use_local_or_Shuffle

Tested, no negative effects seen
twitter · Nov 19, 2013 · 453fa8d · 453fa8d
2 parents b391b3c + 27200bf
commit 453fa8d
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) = {