[FLINK-3307] RMQSourceTest failure

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 0.10.0
• Component/s: Connectors / Common
• Labels: test-stability
• Assignee: Unassigned
• Reporter: Márton Balassi
• Created: 30/Jan/16 07:08
• Updated: 01/Feb/16 11:36
• Resolved: 01/Feb/16 11:36

Description

Running org.apache.flink.streaming.connectors.rabbitmq.RMQSourceTest
java.util.ConcurrentModificationException
at java.util.HashMap$HashIterator.remove(HashMap.java:940)
at java.util.AbstractSet.removeAll(AbstractSet.java:177)
at org.apache.flink.streaming.api.functions.source.MessageAcknowledgingSourceBase.notifyCheckpointComplete(MessageAcknowledgingSourceBase.java:203)
at org.apache.flink.streaming.connectors.rabbitmq.RMQSourceTest$3.run(RMQSourceTest.java:146)
at java.lang.Thread.run(Thread.java:745)
Tests run: 5, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 1.434 sec <<< FAILURE! - in org.apache.flink.streaming.connectors.rabbitmq.RMQSourceTest
testConcurrentAccess(org.apache.flink.streaming.connectors.rabbitmq.RMQSourceTest) Time elapsed: 0.656 sec <<< FAILURE!
java.lang.AssertionError: Test failed with java.util.ConcurrentModificationException
at org.junit.Assert.fail(Assert.java:88)
at org.apache.flink.streaming.connectors.rabbitmq.RMQSourceTest.testConcurrentAccess(RMQSourceTest.java:180)

Results :

Failed tests:
RMQSourceTest.testConcurrentAccess:180 Test failed with java.util.ConcurrentModificationException

Full travis log: https://s3.amazonaws.com/archive.travis-ci.org/jobs/105724919/log.txt

Issue Links

• duplicates: FLINK-3265 RabbitMQ Source not threadsafe: ConcurrentModificationException
• is related to: FLINK-3301 Ineffective synchronization in MessageAcknowledgingSourceBase#restoreState