Closed
Description
# (dtle) src发送第一个（index=0）big tx分割
2022-06-29T15:57:11.758+0800 [DEBUG] client.driver_mgr.dtle: splitting big tx: driver=dtle @module=reader index=0 job=big_tx-migration timestamp=2022-06-29T15:57:11.758+0800
2022-06-29T15:57:11.758+0800 [DEBUG] client.driver_mgr.dtle: sendEntry: driver=dtle @module=reader events=223697 gno=10 isBig=true job=big_tx-migration timestamp=2022-06-29T15:57:11.758+0800
# dst 最后一次执行dml
2022-06-29T15:58:28.505+0800 [DEBUG] client.driver_mgr.dtle: a dml event: driver=dtle @module=dtle.applier.ApplyBinlogEvent job=big_tx-migration timestamp=2022-06-29T15:58:28.504+0800
# src收到dst执行完上述分割后的bigtx_ack
2022-06-29T15:58:28.505+0800 [DEBUG] client.driver_mgr.dtle: bigtx_ack: driver=dtle gno=10 index=0 job=big_tx-migration @module=dtle.extractor timestamp=2022-06-29T15:58:28.505+0800
# src读取一些RowsEvent后，发生同文件rotate（可能是断线重连）
2022-06-29T15:58:28.516+0800 [DEBUG] client.driver_mgr.dtle: got rowsEvent: driver=dtle flags=1 gno=10 schema=action_db_1 table=big_tx @module=reader job=big_tx-migration tableFlags=1 timestamp=2022-06-29T15:58:28.516+0800
2022-06-29T15:58:29.981+0800 [DEBUG] client.driver_mgr.dtle: got rowsEvent: driver=dtle flags=1 job=big_tx-migration schema=action_db_1 tableFlags=1 @module=reader gno=10 table=big_tx timestamp=2022-06-29T15:58:29.980+0800
2022-06-29T15:58:30.614+0800 [INFO] client.driver_mgr.dtle: Rotate to next binlog: driver=dtle @module=reader job=big_tx-migration name=mysql-bin.000002 timestamp=2022-06-29T15:58:30.614+0800
# 这个断线重连似乎是必现的。
# src：重连后会重新从头读取big tx （query=BEGIN）
2022-06-29T15:58:30.615+0800 [DEBUG] client.driver_mgr.dtle: query event: driver=dtle job=big_tx-migration query=BEGIN schema=action_db_1 @module=reader timestamp=2022-06-29T15:58:30.615+0800
# src再次发送index=0分割
2022-06-29T15:59:10.401+0800 [DEBUG] client.driver_mgr.dtle: splitting big tx: driver=dtle @module=reader index=0 job=big_tx-migration timestamp=2022-06-29T15:59:10.401+0800
2022-06-29T15:59:10.401+0800 [DEBUG] client.driver_mgr.dtle: sendEntry: driver=dtle @module=reader events=223697 gno=10 isBig=true job=big_tx-migration timestamp=2022-06-29T15:59:10.401+0800
# dst收到该BinlogEntry，但后续没有处理, 可能是卡在WaitForAllCommitted里了
2022-06-29T15:59:10.968+0800 [DEBUG] client.driver_mgr.dtle: incr. recv a msg.: driver=dtle @module=dtle.applier job=big_tx-migration timestamp=2022-06-29T15:59:10.968+0800
2022-06-29T15:59:11.656+0800 [DEBUG] client.driver_mgr.dtle: a binlogEntry.: driver=dtle gno=10 job=big_tx-migration remaining=0 seq=10 lc=9 @module=dtle.applier timestamp=2022-06-29T15:59:11.655+0800
2022-06-29T15:59:11.660+0800 [DEBUG] client.driver_mgr.dtle: WaitForAllCommitted: driver=dtle lc=9 le=10 timestamp=2022-06-29T15:59:11.660+0800