[ https://issues.apache.org/jira/browse/FLINK-3265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Robert Metzger updated FLINK-3265: ---------------------------------- Component/s: Streaming Connectors > RabbitMQ Source not threadsafe: ConcurrentModificationException > --------------------------------------------------------------- > > Key: FLINK-3265 > URL: https://issues.apache.org/jira/browse/FLINK-3265 > Project: Flink > Issue Type: Improvement > Components: Streaming Connectors > Reporter: Robert Metzger > Assignee: Robert Metzger > Priority: Blocker > Labels: test-stability > > {code} > ------------------------------------------------------- > 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 > {code} > https://s3.amazonaws.com/archive.travis-ci.org/jobs/103452897/log.txt -- This message was sent by Atlassian JIRA (v6.3.4#6332)