0AyanamiRei commented on PR #61325:
URL: https://github.com/apache/doris/pull/61325#issuecomment-4173201750
补充这次 case 调整的逻辑和测试点说明（Kinesis restart 场景）：
1. `test_kinesis_routine_load_restart_fe.groovy`
- 前置：创建 Kinesis stream，等待 ACTIVE + shard ready。
- 创建 routine load 作业后，先写入第一批数据（1~40），并通过轮询等待 `count >= 40`。
- 执行真实 FE 重启：`cluster.restartFrontends(masterFeIndex)`，随后
`context.reconnectFe()`。
- 重启后检查作业状态，断言不为 `CANCELLED`。
- 再写入第二批数据（41~80），轮询等待 `count >= 80`，验证重启后消费可继续推进。
2. `test_kinesis_routine_load_be_restart.groovy`
- 前置与建表建作业流程同上。
- 先写入第一批数据（1~50），等待 `count >= 50`。
- 执行真实 BE 重启：`cluster.restartBackends()`，并通过 `SHOW BACKENDS` 轮询等待全部 Alive。
- 重启后检查作业状态，断言不为 `CANCELLED`。
- 再写入第二批数据（51~100），等待 `count >= 100`，验证 BE 重启后任务可恢复并继续消费。
3. 关于“是否能加重启 BE 测试点”的判断
- 可以加，且已加。
- 参考了 Kafka routine load 的已有用例：
-
`regression-test/suites/load_p0/routine_load/test_routine_load_be_restart.groovy`
- 该用例已覆盖 BE 相关重启/异常恢复语义（通过 debug point + task abort 观测恢复）。
- 基于这个先例，Kinesis 侧增加真实 `restartBackends` 的回归测试点是合理且必要的。
4. 稳定性增强（两用例统一）
- 配置读取统一为 `context.config` 与 `otherConfigs` 兼容。
- 固定 sleep 改为带超时的轮询等待（stream ready、count 达标、backend alive）。
- 清理逻辑增强：`STOP ROUTINE LOAD` 放入 finally，避免异常路径泄露任务。
--
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]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
