Github user srdo commented on a diff in the pull request:
https://github.com/apache/storm/pull/2419#discussion_r150948421
--- Diff:
storm-client/src/jvm/org/apache/storm/coordination/BatchSubtopologyBuilder.java
---
@@ -84,24 +84,24 @@ private BoltDeclarer setBolt(String id, IRichBolt bolt,
Number parallelism) {
p = parallelism.intValue();
}
Component component = new Component(bolt, p);
- _bolts.put(id, component);
+ bolts.put(id, component);
return new BoltDeclarerImpl(component);
}
public void extendTopology(TopologyBuilder builder) {
- BoltDeclarer declarer = builder.setBolt(_masterId, new
CoordinatedBolt(_masterBolt.bolt), _masterBolt.parallelism);
- for (InputDeclaration decl: _masterBolt.declarations) {
+ BoltDeclarer declarer = builder.setBolt(masterId, new
CoordinatedBolt(masterBolt.bolt), masterBolt.parallelism);
+ for (InputDeclaration decl: masterBolt.declarations) {
decl.declare(declarer);
}
- for (Map<String, Object> conf: _masterBolt.componentConfs) {
- declarer.addConfigurations(conf);
+ if (!masterBolt.componentConf.isEmpty()) {
--- End diff --
Nit: addConfigurations seems like it does this check too, so it seems
unnecessary here
---
