[FLINK-3265] RabbitMQ Source not threadsafe: ConcurrentModificationException

• Type: Improvement
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 1.0.0
• Component/s: Connectors / Common
• Labels: test-stability
• Assignee: Maximilian Michels
• Reporter: Robert Metzger
• Created: 20/Jan/16 14:14
• Updated: 01/Feb/16 15:58
• Resolved: 01/Feb/16 15:58

Description

-------------------------------------------------------
 T E S T S
-------------------------------------------------------
Running org.apache.flink.streaming.connectors.rabbitmq.RMQSourceTest
Tests run: 4, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 1.454 sec <<< FAILURE! - in org.apache.flink.streaming.connectors.rabbitmq.RMQSourceTest
testCheckpointing(org.apache.flink.streaming.connectors.rabbitmq.RMQSourceTest)  Time elapsed: 0.902 sec  <<< ERROR!
java.util.ConcurrentModificationException: null
	at java.util.HashMap$HashIterator.remove(HashMap.java:1443)
	at java.util.AbstractSet.removeAll(AbstractSet.java:178)
	at org.apache.flink.streaming.api.functions.source.MessageAcknowledgingSourceBase.notifyCheckpointComplete(MessageAcknowledgingSourceBase.java:198)
	at org.apache.flink.streaming.connectors.rabbitmq.RMQSourceTest.testCheckpointing(RMQSourceTest.java:144)


Results :

Tests in error: 
  RMQSourceTest.testCheckpointing:144 » ConcurrentModification

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

Issue Links

• is duplicated by: FLINK-3301 Ineffective synchronization in MessageAcknowledgingSourceBase#restoreState
• is duplicated by: FLINK-3307 RMQSourceTest failure