stack_trace.log

6-89a4-11e8-88e2-0ac8e5ea0169:1-11 and binlog file 'db-server-mysql-bin.215447', pos=40508711, skipping 0 events plus 1 rows (io.debezium.connector.mysql.BinlogReader:1004)
[2019-05-15 07:41:57,968] INFO Creating thread debezium-mysqlconnector-db-stream.cloud_pxc-binlog-client (io.debezium.util.Threads:267)
[2019-05-15 07:41:57,968] INFO WorkerSourceTask{id=db-stream.dbz.my_db_name-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask:199)
[2019-05-15 07:41:59,969] ERROR Failed to properly convert data value for 'my_db_name.my_table_name.creation_timestamp' of type DATETIME for row [478482, 65180, 3, [123, 34, 97, 100, 100, 105, 116, 105, 111, 110, 97, 108, 95, 105, 110, 102, 111, 114, 109, 97, 116, 105, 111, 110, 34, 58, 34, 100, 111, 110, 101, 34, 125], [91, 123, 34, 113, 117, 101, 115, 116, 105, 111, 110, 34, 58, 34, 87, 104, 97, 116, 32, 115, 104, 111, 117, 108, 100, 32, 98, 101, 32, 82, 69, 77, 79, 86, 69, 68, 32, 102, 114, 111, 109, 32, 121, 111, 117, 114, 32, 112, 114, 111, 100, 117, 99, 116, 63, 34, 44, 34, 97, 110, 115, 119, 101, 114, 34, 58, 34, 38, 35, 49, 56, 51, 59, 32, 32, 97, 110, 100, 32, 70, 114, 101, 110, 99, 104, 41, 92, 110, 38, 35, 49, 56, 51, 59, 32, 92, 117, 50, 48, 50, 50, 32, 65, 32, 109, 105, 110, 105, 109, 117, 109, 32, 111, 102, 32, 50, 32, 112, 101, 111, 112, 108, 101, 32, 112, 101, 114, 32, 98, 111, 111, 107, 105, 110, 103, 32, 105, 115, 32, 114, 101, 113, 117, 105, 114, 101, 100, 92, 110, 38, 35, 49, 56, 51, 59, 32, 92, 117, 50, 48, 50, 50, 32, 73, 110, 102, 97, 110, 116, 32, 48, 45, 51, 32, 121, 101, 97, 114, 115, 32, 97, 114, 101, 32, 102, 114, 101, 101, 32, 40, 116, 97, 115, 116, 105, 110, 103, 32, 110, 111, 116, 32, 105, 110, 99, 108, 117, 100, 101, 100, 41, 46, 34, 125, 44, 123, 34, 113, 117, 101, 115, 116, 105, 111, 110, 34, 58, 34, 87, 104, 97, 116, 32, 115, 104, 111, 117, 108, 100, 32, 98, 101, 32, 65, 68, 68, 69, 68, 32, 116, 111, 32, 121, 111, 117, 114, 32, 112, 114, 111, 100, 117, 99, 116, 63, 34, 44, 34, 97, 110, 115, 119, 101, 114, 34, 58, 34, 38, 35, 49, 56, 51, 59, 32, 89, 111, 117, 32, 109, 117, 115, 116, 32, 98, 101, 32, 97, 116, 32, 116, 104, 101, 32, 100, 101, 112, 97, 114, 116, 117, 114, 101, 32, 112, 111, 105, 110, 116, 32, 49, 48, 32, 109, 105, 110, 117, 116, 101, 115, 32, 105, 110, 32, 97, 100, 118, 97, 110, 99, 101, 46, 32, 92, 110, 38, 35, 49, 56, 51, 59, 32, 92, 110, 38, 35, 49, 56, 51, 59, 34, 125, 93], null, null, [], 2019-05-09T15:59:26, 2, 2019-05-13T12:50:57Z, 1, 61560]: (io.debezium.relational.TableSchemaBuilder:233)
java.lang.IllegalArgumentException: Unexpected value for JDBC type 93 and column creation_timestamp DATETIME NOT NULL: class=class [B
	at io.debezium.jdbc.JdbcValueConverters.handleUnknownData(JdbcValueConverters.java:1164)
	at io.debezium.jdbc.JdbcValueConverters.convertValue(JdbcValueConverters.java:1207)
	at io.debezium.jdbc.JdbcValueConverters.convertTimestampToEpochMillis(JdbcValueConverters.java:441)
	at io.debezium.jdbc.JdbcValueConverters.lambda$converter$20(JdbcValueConverters.java:337)
	at io.debezium.relational.ValueConverter.lambda$and$1(ValueConverter.java:50)
	at io.debezium.relational.TableSchemaBuilder.lambda$createValueGenerator$2(TableSchemaBuilder.java:229)
	at io.debezium.relational.TableSchema.valueFromColumnData(TableSchema.java:145)
	at io.debezium.connector.mysql.RecordMakers$1.update(RecordMakers.java:263)
	at io.debezium.connector.mysql.RecordMakers$RecordsForTable.update(RecordMakers.java:481)
	at io.debezium.connector.mysql.BinlogReader.handleUpdate(BinlogReader.java:876)
	at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:492)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1095)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:943)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:580)
	at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:825)
	at java.lang.Thread.run(Thread.java:748)
[2019-05-15 07:41:59,969] WARN Unexpected value for JDBC type 1 and column requester_user_type ENUM(1) CHARSET utf8 DEFAULT VALUE NULL: class=java.time.LocalDateTime (io.debezium.connector.mysql.MySqlValueConverters:1157)
[2019-05-15 07:41:59,969] ERROR Failed to properly convert data value for 'gyg.my_table_name.update_timestamp' of type TIMESTAMP for row [478482, 65180, 3, [123, 34, 97, 100, 100, 105, 116, 105, 111, 110, 97, 108, 95, 105, 110, 102, 111, 114, 109, 97, 116, 105, 111, 110, 34, 58, 34, 100, 111, 110, 101, 34, 125], [91, 123, 34, 113, 117, 101, 115, 116, 105, 111, 110, 34, 58, 34, 87, 104, 97, 116, 32, 115, 104, 111, 117, 108, 100, 32, 98, 101, 32, 82, 69, 77, 79, 86, 69, 68, 32, 102, 114, 111, 109, 32, 121, 111, 117, 114, 32, 112, 114, 111, 100, 117, 99, 116, 63, 34, 44, 34, 97, 110, 115, 119, 101, 114, 34, 58, 34, 38, 35, 49, 56, 51, 59, 32, 32, 97, 110, 100, 32, 70, 114, 101, 110, 99, 104, 41, 92, 110, 38, 35, 49, 56, 51, 59, 32, 92, 117, 50, 48, 50, 50, 32, 65, 32, 109, 105, 110, 105, 109, 117, 109, 32, 111, 102, 32, 50, 32, 112, 101, 111, 112, 108, 101, 32, 112, 101, 114, 32, 98, 111, 111, 107, 105, 110, 103, 32, 105, 115, 32, 114, 101, 113, 117, 105, 114, 101, 100, 92, 110, 38, 35, 49, 56, 51, 59, 32, 92, 117, 50, 48, 50, 50, 32, 73, 110, 102, 97, 110, 116, 32, 48, 45, 51, 32, 121, 101, 97, 114, 115, 32, 97, 114, 101, 32, 102, 114, 101, 101, 32, 40, 116, 97, 115, 116, 105, 110, 103, 32, 110, 111, 116, 32, 105, 110, 99, 108, 117, 100, 101, 100, 41, 46, 34, 125, 44, 123, 34, 113, 117, 101, 115, 116, 105, 111, 110, 34, 58, 34, 87, 104, 97, 116, 32, 115, 104, 111, 117, 108, 100, 32, 98, 101, 32, 65, 68, 68, 69, 68, 32, 116, 111, 32, 121, 111, 117, 114, 32, 112, 114, 111, 100, 117, 99, 116, 63, 34, 44, 34, 97, 110, 115, 119, 101, 114, 34, 58, 34, 38, 35, 49, 56, 51, 59, 32, 89, 111, 117, 32, 109, 117, 115, 116, 32, 98, 101, 32, 97, 116, 32, 116, 104, 101, 32, 100, 101, 112, 97, 114, 116, 117, 114, 101, 32, 112, 111, 105, 110, 116, 32, 49, 48, 32, 109, 105, 110, 117, 116, 101, 115, 32, 105, 110, 32, 97, 100, 118, 97, 110, 99, 101, 46, 32, 92, 110, 38, 35, 49, 56, 51, 59, 32, 92, 110, 38, 35, 49, 56, 51, 59, 34, 125, 93], null, null, [], 2019-05-09T15:59:26, 2, 2019-05-13T12:50:57Z, 1, 61560]: (io.debezium.relational.TableSchemaBuilder:233)
java.lang.IllegalArgumentException: Unexpected value for JDBC type 2014 and column update_timestamp TIMESTAMP NOT NULL DEFAULT VALUE 1970-01-01T00:00:00Z: class=class java.lang.Integer
	at io.debezium.jdbc.JdbcValueConverters.handleUnknownData(JdbcValueConverters.java:1164)
	at io.debezium.jdbc.JdbcValueConverters.convertValue(JdbcValueConverters.java:1207)
	at io.debezium.jdbc.JdbcValueConverters.convertTimestampWithZone(JdbcValueConverters.java:392)
	at io.debezium.jdbc.JdbcValueConverters.lambda$converter$25(JdbcValueConverters.java:348)
	at io.debezium.relational.TableSchemaBuilder.lambda$createValueGenerator$2(TableSchemaBuilder.java:229)
	at io.debezium.relational.TableSchema.valueFromColumnData(TableSchema.java:145)
	at io.debezium.connector.mysql.RecordMakers$1.update(RecordMakers.java:263)
	at io.debezium.connector.mysql.RecordMakers$RecordsForTable.update(RecordMakers.java:481)
	at io.debezium.connector.mysql.BinlogReader.handleUpdate(BinlogReader.java:876)
	at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:492)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1095)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:943)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:580)
	at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:825)
	at java.lang.Thread.run(Thread.java:748)
[2019-05-15 07:41:59,969] WARN Unexpected value for JDBC type 1 and column update_user_type ENUM(1) CHARSET utf8 DEFAULT VALUE NULL: class=java.time.ZonedDateTime (io.debezium.connector.mysql.MySqlValueConverters:1157)
[2019-05-15 07:41:59,969] WARN Unexpected value for JDBC type 1 and column requester_user_type ENUM(1) CHARSET utf8 DEFAULT VALUE NULL: class=java.time.LocalDateTime (io.debezium.connector.mysql.MySqlValueConverters:1157)
[2019-05-15 07:41:59,969] ERROR Failed to properly convert data value for 'gyg.my_table_name.update_timestamp' of type TIMESTAMP for row [478482, 65180, 2, [123, 34, 97, 100, 100, 105, 116, 105, 111, 110, 97, 108, 95, 105, 110, 102, 111, 114, 109, 97, 116, 105, 111, 110, 34, 58, 34, 100, 111, 110, 101, 34, 125], [91, 123, 34, 113, 117, 101, 115, 116, 105, 111, 110, 34, 58, 34, 87, 104, 97, 116, 32, 115, 104, 111, 117, 108, 100, 32, 98, 101, 32, 82, 69, 77, 79, 86, 69, 68, 32, 102, 114, 111, 109, 32, 121, 111, 117, 114, 32, 112, 114, 111, 100, 117, 99, 116, 63, 34, 44, 34, 97, 110, 115, 119, 101, 114, 34, 58, 34, 38, 35, 49, 56, 51, 59, 32, 32, 97, 110, 100, 32, 70, 114, 101, 110, 99, 104, 41, 92, 110, 38, 35, 49, 56, 51, 59, 32, 92, 117, 50, 48, 50, 50, 32, 65, 32, 109, 105, 110, 105, 109, 117, 109, 32, 111, 102, 32, 50, 32, 112, 101, 111, 112, 108, 101, 32, 112, 101, 114, 32, 98, 111, 111, 107, 105, 110, 103, 32, 105, 115, 32, 114, 101, 113, 117, 105, 114, 101, 100, 92, 110, 38, 35, 49, 56, 51, 59, 32, 92, 117, 50, 48, 50, 50, 32, 73, 110, 102, 97, 110, 116, 32, 48, 45, 51, 32, 121, 101, 97, 114, 115, 32, 97, 114, 101, 32, 102, 114, 101, 101, 32, 40, 116, 97, 115, 116, 105, 110, 103, 32, 110, 111, 116, 32, 105, 110, 99, 108, 117, 100, 101, 100, 41, 46, 34, 125, 44, 123, 34, 113, 117, 101, 115, 116, 105, 111, 110, 34, 58, 34, 87, 104, 97, 116, 32, 115, 104, 111, 117, 108, 100, 32, 98, 101, 32, 65, 68, 68, 69, 68, 32, 116, 111, 32, 121, 111, 117, 114, 32, 112, 114, 111, 100, 117, 99, 116, 63, 34, 44, 34, 97, 110, 115, 119, 101, 114, 34, 58, 34, 38, 35, 49, 56, 51, 59, 32, 89, 111, 117, 32, 109, 117, 115, 116, 32, 98, 101, 32, 97, 116, 32, 116, 104, 101, 32, 100, 101, 112, 97, 114, 116, 117, 114, 101, 32, 112, 111, 105, 110, 116, 32, 49, 48, 32, 109, 105, 110, 117, 116, 101, 115, 32, 105, 110, 32, 97, 100, 118, 97, 110, 99, 101, 46, 32, 92, 110, 38, 35, 49, 56, 51, 59, 32, 92, 110, 38, 35, 49, 56, 51, 59, 34, 125, 93], null, null, null, 2019-05-09T15:59:26, 2, 2019-05-13T12:50:53Z, 1, 61560]: (io.debezium.relational.TableSchemaBuilder:233)
java.lang.IllegalArgumentException: Unexpected value for JDBC type 2014 and column update_timestamp TIMESTAMP NOT NULL DEFAULT VALUE 1970-01-01T00:00:00Z: class=class java.lang.Integer
	at io.debezium.jdbc.JdbcValueConverters.handleUnknownData(JdbcValueConverters.java:1164)
	at io.debezium.jdbc.JdbcValueConverters.convertValue(JdbcValueConverters.java:1207)
	at io.debezium.jdbc.JdbcValueConverters.convertTimestampWithZone(JdbcValueConverters.java:392)
	at io.debezium.jdbc.JdbcValueConverters.lambda$converter$25(JdbcValueConverters.java:348)
	at io.debezium.relational.TableSchemaBuilder.lambda$createValueGenerator$2(TableSchemaBuilder.java:229)
	at io.debezium.relational.TableSchema.valueFromColumnData(TableSchema.java:145)
	at io.debezium.connector.mysql.RecordMakers$1.update(RecordMakers.java:266)
	at io.debezium.connector.mysql.RecordMakers$RecordsForTable.update(RecordMakers.java:481)
	at io.debezium.connector.mysql.BinlogReader.handleUpdate(BinlogReader.java:876)
	at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:492)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1095)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:943)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:580)
	at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:825)
	at java.lang.Thread.run(Thread.java:748)
[2019-05-15 07:41:59,969] WARN Unexpected value for JDBC type 1 and column update_user_type ENUM(1) CHARSET utf8 DEFAULT VALUE NULL: class=java.time.ZonedDateTime (io.debezium.connector.mysql.MySqlValueConverters:1157)
[2019-05-15 07:41:59,970] ERROR Error during binlog processing. Last offset stored = null, binlog reader near position = db-server-mysql-bin.215447/40513039 (io.debezium.connector.mysql.BinlogReader:1054)
[2019-05-15 07:41:59,970] ERROR Failed due to error: Error processing binlog event (io.debezium.connector.mysql.BinlogReader:209)
org.apache.kafka.connect.errors.ConnectException: Invalid value: null used for required field: "creation_timestamp", schema type: INT64
	at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:230)
	at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:208)
	at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:508)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1095)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:943)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:580)
	at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:825)
	at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.kafka.connect.errors.DataException: Invalid value: null used for required field: "creation_timestamp", schema type: INT64
	at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:220)
	at org.apache.kafka.connect.data.Struct.validate(Struct.java:233)
	at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:248)
	at org.apache.kafka.connect.data.Struct.put(Struct.java:216)
	at org.apache.kafka.connect.data.Struct.put(Struct.java:203)
	at io.debezium.data.Envelope.update(Envelope.java:295)
	at io.debezium.connector.mysql.RecordMakers$1.update(RecordMakers.java:295)
	at io.debezium.connector.mysql.RecordMakers$RecordsForTable.update(RecordMakers.java:481)
	at io.debezium.connector.mysql.BinlogReader.handleUpdate(BinlogReader.java:876)
	at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:492)
	... 5 more
[2019-05-15 07:41:59,970] INFO Error processing binlog event, and propagating to Kafka Connect so it stops this connector. Future binlog events read before connector is shutdown will be ignored. (io.debezium.connector.mysql.BinlogReader:513)
[2019-05-15 07:42:00,376] INFO WorkerSourceTask{id=db-stream.dbz.gyg-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:397)
[2019-05-15 07:42:00,376] INFO WorkerSourceTask{id=db-stream.dbz.gyg-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:414)
[2019-05-15 07:42:00,376] ERROR WorkerSourceTask{id=db-stream.dbz.gyg-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:177)
org.apache.kafka.connect.errors.ConnectException: Invalid value: null used for required field: "creation_timestamp", schema type: INT64
	at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:230)
	at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:208)
	at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:508)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1095)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:943)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:580)
	at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:825)
	at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.kafka.connect.errors.DataException: Invalid value: null used for required field: "creation_timestamp", schema type: INT64
	at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:220)
	at org.apache.kafka.connect.data.Struct.validate(Struct.java:233)
	at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:248)
	at org.apache.kafka.connect.data.Struct.put(Struct.java:216)
	at org.apache.kafka.connect.data.Struct.put(Struct.java:203)
	at io.debezium.data.Envelope.update(Envelope.java:295)
	at io.debezium.connector.mysql.RecordMakers$1.update(RecordMakers.java:295)
	at io.debezium.connector.mysql.RecordMakers$RecordsForTable.update(RecordMakers.java:481)
	at io.debezium.connector.mysql.BinlogReader.handleUpdate(BinlogReader.java:876)
	at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:492)
	... 5 more