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

Concurrent access to a thread map

    Details

      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 

        Gliffy Diagrams

          Attachments

            Activity

              People

              • Assignee:
                jpechanec Jiri Pechanec
                Reporter:
                jpechanec Jiri Pechanec
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: