ConcurrentModificationExceptions in WindowedBoltExecutorTest

[abhishekagarwal87]

Printing testWindowedBolt.tupleWindows results in tupleWindows being iterated while being modified at same time.

[HeartSaVioR]

@abhishekagarwal87
Is it a fix for this random failure?

classname: org.apache.storm.topology.WindowedBoltExecutorTest / testname: testExecuteWithLateTupleStream
org.mockito.exceptions.verification.WantedButNotInvoked: Wanted but not invoked:
outputCollector.emit(
"$late",
[source: null:1, stream: s1, id: {}, [600]],
[source: null:1, stream: s1, id: {}, [600]]
);
-> at org.apache.storm.topology.WindowedBoltExecutorTest.testExecuteWithLateTupleStream(WindowedBoltExecutorTest.java:225)
Actually, there were zero interactions with this mock.
at org.apache.storm.topology.WindowedBoltExecutorTest.testExecuteWithLateTupleStream(WindowedBoltExecutorTest.java:225)

[abhishekagarwal87]

No there was another error in the same test

classname: org.apache.storm.topology.WindowedBoltExecutorTest / testname: testExecuteWithLateTupleStream
java.util.ConcurrentModificationException: null
at java.util.ArrayList$Itr.checkForComodification(ArrayList.java:859)
at java.util.ArrayList$Itr.next(ArrayList.java:831)
at java.util.AbstractCollection.toString(AbstractCollection.java:457)
at java.lang.String.valueOf(String.java:2849)
at java.io.PrintStream.println(PrintStream.java:821)
at org.apache.storm.topology.WindowedBoltExecutorTest.testExecuteWithLateTupleStream(WindowedBoltExecutorTest.java:223)

I see now that this fix itself may not suffice. Let me dig deeper and try to find a solution.

[HeartSaVioR]

Got it. Thanks. :)