fivewords
fivewords
> JDBC连接地址加个参数允许一次执行多条SQL allowMultiQueries=true：例如jdbc:mysql://xxxx:3306/dss?characterEncoding=UTF-8&allowMultiQueries=true 完美
es官方支持的sql语句很有限，比如 sql的嵌套都是不可以的
I found that in the binlog merge stage of the full snapshot, if the binlog reading is abnormal (cannot be deserialized, network abnormality), the binlog reading will stop at this...
However, I just tested, if it is a new task, single-table pull, no problem occurs
com.github.shyiko.mysql.binlog.event.deserialization.EventDataDeserializationException: Failed to deserialize data of EventHeaderV4{timestamp=1656487905000, eventType=UPDATE_ROWS, serverId=3318594750, headerLength=19, dataLength=467, nextPosition=24906517, flags=0}
ok,,,, It seems to work (*^▽^*) I added a three-second sleep for MySqlSourceEnumerator to deliver shards -> MySqlSourceEnumerator#handleSplitRequest ``` @Override public void handleSplitRequest(int subtaskId, @Nullable String requesterHostname) { if (!context.registeredReaders().containsKey(subtaskId))...
When the daytime business is relatively high, 3s seems not enough, need sleep 5s
When I rewrote the class, the problem doesn't seem to appear, I tried 3 times with success. I will test it again tomorrow. At this point, I suspect that some...
> When I rewrote the class, the problem doesn't seem to appear, I tried 3 times with success. I will test it again tomorrow. At this point, I suspect that...
> @lykpass 我用cdc2.2.1也出现了这个问题 但是程序不会导致无限重启 请问后续您有什么好的解决办法吗？ 我们是在现有任务加上新表的时候出现，我通过debug才发现有一个序列化错误，导致卡在拉取那里，不知道你们现在解决了吗？