Hi! I’m working on a storm topology where I have a stateful bolt that has two inputs, one is from a kinesis spout going through a set of bolts and one is from a clock spout that emits tuples based on a cron expression.
My issue is that I get a ConcurrentModificationException from TopologyBuilder when i create the topology. I get it from the method TopologyBuilder.addCheckPointInputs(…), that method adds inputs to the same set of inputs that it’s iterating over, hence ConcurrentModification. Is there any way around this or do i need to wait for a fix? and when could a fix be available? Best Regards Henrik Lindholm
