java.lang.RuntimeException: com.github.shyiko.mysql.binlog.event.deserialization.EventDataDeserializationException: Failed to deserialize data of EventHeaderV4{timestamp=1634295645000, eventType=EXT_WRITE_ROWS, serverId=2, headerLength=19, dataLength=129, nextPosition=997226401, flags=0}

[ghost]

I have three tasks. The code logic is the same, but the data source is different, and there are two tasks running all the time without any problems. But another task run for a while and reported an error.

Caused by: java.lang.RuntimeException: com.github.shyiko.mysql.binlog.event.deserialization.EventDataDeserializationException: Failed to deserialize data of EventHeaderV4{timestamp=1634295645000, eventType=EXT_WRITE_ROWS, serverId=2, headerLength=19, dataLength=129, nextPosition=997226401, flags=0}
at io.debezium.connector.mysql.BinlogReader.handleServerIncident(BinlogReader.java:675) ~[flink-sql-connector-mysql-cdc-1.2.0.jar:1.2.0]
at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:590) ~[flink-sql-connector-mysql-cdc-1.2.0.jar:1.2.0]
at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1104) ~[flink-sql-connector-mysql-cdc-1.2.0.jar:1.2.0]
at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:955) ~[flink-sql-connector-mysql-cdc-1.2.0.jar:1.2.0]
at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:595) ~[flink-sql-connector-mysql-cdc-1.2.0.jar:1.2.0]
at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:839) ~[flink-sql-connector-mysql-cdc-1.2.0.jar:1.2.0]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_144]
Caused by: com.github.shyiko.mysql.binlog.event.deserialization.EventDataDeserializationException: Failed to deserialize data of EventHeaderV4{timestamp=1634295645000, eventType=EXT_WRITE_ROWS, serverId=2, headerLength=19, dataLength=129, nextPosition=997226401, flags=0}
at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.deserializeEventData(EventDeserializer.java:304) ~[flink-sql-connector-mysql-cdc-1.2.0.jar:1.2.0]
at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.nextEvent(EventDeserializer.java:227) ~[flink-sql-connector-mysql-cdc-1.2.0.jar:1.2.0]
at io.debezium.connector.mysql.BinlogReader$1.nextEvent(BinlogReader.java:252) ~[flink-sql-connector-mysql-cdc-1.2.0.jar:1.2.0]
at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:934) ~[flink-sql-connector-mysql-cdc-1.2.0.jar:1.2.0]
at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:595) ~[flink-sql-connector-mysql-cdc-1.2.0.jar:1.2.0]
at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:839) ~[flink-sql-connector-mysql-cdc-1.2.0.jar:1.2.0]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_144]
Caused by: java.io.EOFException
at com.github.shyiko.mysql.binlog.io.ByteArrayInputStream.read(ByteArrayInputStream.java:192) ~[flink-sql-connector-mysql-cdc-1.2.0.jar:1.2.0]
at java.io.InputStream.read(InputStream.java:170) ~[?:1.8.0_144]
at java.io.InputStream.skip(InputStream.java:224) ~[?:1.8.0_144]
at com.github.shyiko.mysql.binlog.io.ByteArrayInputStream.skipToTheEndOfTheBlock(ByteArrayInputStream.java:219) ~[flink-sql-connector-mysql-cdc-1.2.0.jar:1.2.0]
at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.deserializeEventData(EventDeserializer.java:300) ~[flink-sql-connector-mysql-cdc-1.2.0.jar:1.2.0]
at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.nextEvent(EventDeserializer.java:227) ~[flink-sql-connector-mysql-cdc-1.2.0.jar:1.2.0]
at io.debezium.connector.mysql.BinlogReader$1.nextEvent(BinlogReader.java:252) ~[flink-sql-connector-mysql-cdc-1.2.0.jar:1.2.0]
at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:934) ~[flink-sql-connector-mysql-cdc-1.2.0.jar:1.2.0]
at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:595) ~[flink-sql-connector-mysql-cdc-1.2.0.jar:1.2.0]
at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:839) ~[flink-sql-connector-mysql-cdc-1.2.0.jar:1.2.0]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_144]

[leonardBang]

could you try to use another serverId?" current it is '2' from your post logs. I doubt the serverId conficts.

[ghost]

I used three serverids: 5410,5411,5412. I did not use 2. I went to check the binlog, and there was no binlog in the log

[ghost]

could you try to use another serverId?" current it is '2' from your post logs. I doubt the serverId conficts.

I started in Standalone mode, I looked at the task and upstream had just modified a table structure in the same library that I hadn't synchronized before reporting an error. When a binlog is parsed into a Struct, jobManager saves all tables in the table structure, parses all binlogs, and then filters all tables that need to be synchronized. So if I change the result of a table that I didn't synchronize, the next time I parse the binlog of that table, I'll get an error.