Github user srdo commented on a diff in the pull request:
https://github.com/apache/storm/pull/2419#discussion_r150950920
--- Diff:
storm-client/src/jvm/org/apache/storm/trident/topology/TridentTopologyBuilder.java
---
@@ -104,8 +104,8 @@ public static String spoutIdFromCoordinatorId(String
coordId) {
}
Map<GlobalStreamId, String> fleshOutStreamBatchIds(boolean
includeCommitStream) {
- Map<GlobalStreamId, String> ret = new HashMap<>(_batchIds);
- Set<String> allBatches = new HashSet(_batchIds.values());
+ Map<GlobalStreamId, String> ret = new HashMap<>(batchIds);
+ Set<String> allBatches = new HashSet(batchIds.values());
--- End diff --
Also raw here.
---
