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

Concurrent access to a thread map

XMLWordPrintable

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

      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 

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

                Created:
                Updated:
                Resolved: