-
Bug
-
Resolution: Done
-
Major
-
None
-
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