Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-3265

RabbitMQ Source not threadsafe: ConcurrentModificationException

    XMLWordPrintableJSON

Details

    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

      Attachments

        Issue Links

          Activity

            People

              mxm Maximilian Michels
              rmetzger Robert Metzger
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: