zhaoysg commented on PR #11113: URL: https://github.com/apache/seatunnel/pull/11113#issuecomment-4737021224
感谢详细 review。 我已经补了一个针对 TiDB CDC 乱序事件路径的聚焦回归测试： `TiDBSourceReaderTest#flushRowsShouldHoldCommitUntilMatchingPrewriteArrives`。 这个测试覆盖 review 中提到的关键状态转换： 1. 先收到 COMMIT； 2. resolvedTs 已经超过 commitTs 时调用 flushRows，并验证 commit 会被保留，同时 safeResolvedTs 降到 commitTs - 1； 3. 后续收到匹配的 PREWRITE； 4. 再次调用 flushRows，验证 prewrite row 会被发出，并且 pending commit/prewrite 状态被清空。 本地验证： - `./mvnw.cmd -pl seatunnel-connectors-v2/connector-cdc/connector-cdc-tidb test` - `./mvnw.cmd -q -pl seatunnel-connectors-v2/connector-cdc/connector-cdc-tidb -DskipTests verify` 以上两个命令均通过。 我也尝试了全仓 `./mvnw.cmd -q -DskipTests verify`，但在解析 `org.apache.flink:flink-statebackend-rocksdb:1.20.1` 时 Maven Central TLS handshake/download 失败，构建在到达本模块前中断。 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
