Details
-
Bug
-
Status: Resolved
-
P1
-
Resolution: Fixed
-
None
Description
shouldStopReadersPoolAlsoWhenExceptionsOccurDuringStopping fails due to incomplete interactions with the mock.
Wanted but not invoked: firstIterator.readNextBatch(); -> at org.apache.beam.sdk.io.kinesis.ShardReadersPoolTest.shouldStopReadersPoolAlsoWhenExceptionsOccurDuringStopping(ShardReadersPoolTest.java:244) However, there were other interactions with this mock: -> at org.apache.beam.sdk.io.kinesis.ShardReadersPoolTest.shouldStopReadersPoolAlsoWhenExceptionsOccurDuringStopping(ShardReadersPoolTest.java:241)