Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-2278

Concurrent access to a thread map

    XMLWordPrintable

Details

    • Bug
    • Resolution: Done
    • Major
    • 1.2.1.Final
    • None
    • mysql-connector
    • None

    Description

      The access to the thread map is synchronized but that does not include iterator

       

      org.apache.kafka.connect.errors.ConnectException: Unable to connect to the MySQL database at localhost:3306 with user 'snapper': null
      	at io.debezium.connector.mysql.BinlogReader.doStart(BinlogReader.java:445)
      	at io.debezium.connector.mysql.AbstractReader.start(AbstractReader.java:116)
      	at io.debezium.connector.mysql.ChainedReader.startNextReader(ChainedReader.java:206)
      	at io.debezium.connector.mysql.ChainedReader.start(ChainedReader.java:103)
      	at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:279)
      	at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:101)
      	at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:756)
      	at io.debezium.embedded.AbstractConnectorTest.lambda$start$3(AbstractConnectorTest.java:331)
      	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
      	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
      	at java.lang.Thread.run(Thread.java:748)
      Caused by: java.util.ConcurrentModificationException
      	at java.util.HashMap$HashIterator.nextNode(HashMap.java:1445)
      	at java.util.HashMap$KeyIterator.next(HashMap.java:1469)
      	at io.debezium.connector.mysql.BinlogReader.doStart(BinlogReader.java:417)
      	... 10 more 

      Attachments

        Activity

          People

            jpechane Jiri Pechanec
            jpechane Jiri Pechanec
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: