-
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 | | | +-------------------------+----------+--------------+------------------+