From 27200bfc8a112b5588337813fe57375f7cf4843b Mon Sep 17 00:00:00 2001 From: Ian O Connell Date: Mon, 18 Nov 2013 17:21:37 -0800 Subject: [PATCH] Tested, no negative effects seen --- .../scala/com/twitter/summingbird/storm/StormPlatform.scala | 2 +- 1 file changed, 1 insertion(+), 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 index 517b99845..8f2eb1cf2 100644 --- 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) = {