davidzollo commented on PR #10551: URL: https://github.com/apache/seatunnel/pull/10551#issuecomment-5142014987
本轮已针对最新 CI 失败做修复：Build 里 engine-v2-it 的 `CheckpointEnableIT.testZetaStreamingCheckpointInterval` 和 `testZetaStreamingCheckpointNoInterval` 在 restore 后等待 sink assert 超时。原因是 #10551 新增的 generation fence 只按 `jobId` 检查 pending cleanup；同一个 jobId 立即从 savepoint restore 时，旧 generation 的延迟 cleanup 记录还可能存在，导致新 generation 的 checkpoint/ready-to-close 状态写入被误阻断。\n\n修复：`JobMaster.isStatePersistenceAllowed()` 现在只拦截 ownerInitializationTimestamp 等于当前 generation 的 cleanup record；旧 generation cleanup 不再 fence 当前 restore generation，同时保留当前 generation terminal cleanup 对 late writer 的防护。已补充 `JobMasterTest.testOldGenerationCleanupDoesNotFenceCurrentGeneration` 覆盖这个场景。\n\n本地按任务边界只执行格式验证：`./mvnw -pl seatunnel-engine/seatunnel-engine-server spotless:apply` 和 `spotle ss:check` 均通过；未运行本地 compile/test/E2E。已推送到 PR head，等待 GitHub CI 重跑。 -- 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]
