-
Bug
-
Resolution: Done
-
Major
-
0.3.5
-
None
[2016-11-28 13:10:41,915] INFO Step 8: scanned 1251477 rows in 2 tables in 00:01:53.939 (io.debezium.connector.mysql.SnapshotReader:417) [2016-11-28 13:10:41,915] INFO Step 9: committing transaction (io.debezium.connector.mysql.SnapshotReader:458) [2016-11-28 13:10:41,951] INFO Completed snapshot in 00:01:55.293 (io.debezium.connector.mysql.SnapshotReader:471) [2016-11-28 13:10:42,695] INFO Finished WorkerSourceTask{id=pay_sandbox_connector-0} commitOffsets successfully in 1 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:356) [2016-11-28 13:10:42,696] ERROR Task pay_sandbox_connector-0 threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:142) org.apache.kafka.connect.errors.ConnectException: Unexpected error while connecting to MySQL and looking at GTID mode: at io.debezium.connector.mysql.MySqlJdbcContext.knownGtidSet(MySqlJdbcContext.java:140) at io.debezium.connector.mysql.BinlogReader.doStart(BinlogReader.java:160) at io.debezium.connector.mysql.AbstractReader.start(AbstractReader.java:66) at io.debezium.connector.mysql.MySqlConnectorTask.transitionToReadBinlog(MySqlConnectorTask.java:267) at io.debezium.connector.mysql.SnapshotReader.doCleanup(SnapshotReader.java:140) at io.debezium.connector.mysql.AbstractReader.poll(AbstractReader.java:195) at io.debezium.connector.mysql.MySqlConnectorTask.poll(MySqlConnectorTask.java:203) at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:155) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:140) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:175) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) Caused by: java.sql.SQLException: Column Index out of range, 5 > 4. at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:964) at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:897) at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:886) at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:860) at com.mysql.jdbc.ResultSetImpl.checkColumnBounds(ResultSetImpl.java:767) at com.mysql.jdbc.ResultSetImpl.getStringInternal(ResultSetImpl.java:5229) at com.mysql.jdbc.ResultSetImpl.getString(ResultSetImpl.java:5151) at io.debezium.connector.mysql.MySqlJdbcContext.lambda$knownGtidSet$1(MySqlJdbcContext.java:136) at io.debezium.jdbc.JdbcConnection.query(JdbcConnection.java:308) at io.debezium.jdbc.JdbcConnection.query(JdbcConnection.java:287) at io.debezium.connector.mysql.MySqlJdbcContext.knownGtidSet(MySqlJdbcContext.java:134) ... 14 more
in homolog it's run MySQL 5.6
show master status; +-------------------------+----------+--------------+------------------+-------------------+ | File | Position | Binlog_Do_DB | Binlog_Ignore_DB | Executed_Gtid_Set | +-------------------------+----------+--------------+------------------+-------------------+ | mysqlhomolog-bin.000507 | 49987 | | | | +-------------------------+----------+--------------+------------------+-------------------+
in sandbox it's run MySQL 5.1
show master status; +-------------------------+----------+--------------+------------------+ | File | Position | Binlog_Do_DB | Binlog_Ignore_DB | +-------------------------+----------+--------------+------------------+ | mysqlsandbox-bin.000507 | 687122 | | | +-------------------------+----------+--------------+------------------+