Permalink
Browse files

set component configurations correctly for trident spouts

  • Loading branch information...
1 parent f4e7e37 commit 905b8e7745ac78005d82e0ca2b8c9f8f8c90ad9f @nathanmarz nathanmarz committed Feb 12, 2013
Showing with 1 addition and 1 deletion.
  1. +1 −1 src/jvm/storm/trident/topology/TridentTopologyBuilder.java
@@ -164,7 +164,7 @@ public StormTopology buildTopology() {
bd.allGrouping(masterCoordinator(batchGroup), MasterBatchCoordinator.COMMIT_STREAM_ID);
}
for(Map m: c.componentConfs) {
- scd.addConfigurations(m);
+ bd.addConfigurations(m);
}
}
}

0 comments on commit 905b8e7

Please sign in to comment.