diff --git a/src/main/java/com/ycwl/basic/service/task/RenderJobPollingService.java b/src/main/java/com/ycwl/basic/service/task/RenderJobPollingService.java index bfdb70e2..8444443f 100644 --- a/src/main/java/com/ycwl/basic/service/task/RenderJobPollingService.java +++ b/src/main/java/com/ycwl/basic/service/task/RenderJobPollingService.java @@ -51,9 +51,9 @@ public class RenderJobPollingService { private final MemberRelationRepository memberRelationRepository; /** - * 定时轮询间隔:5秒 + * 定时轮询间隔:4秒 */ - private static final int POLL_INTERVAL_SECONDS = 5; + private static final int POLL_INTERVAL_SECONDS = 4; /** * 每次查询的最大记录数 @@ -62,9 +62,9 @@ public class RenderJobPollingService { /** * 定时轮询渲染作业状态 - * 每5秒执行一次 + * 每3秒执行一次 */ - @Scheduled(fixedDelay = 5000, initialDelay = 10000) + @Scheduled(fixedDelay = 3000) public void pollRenderJobs() { try { log.debug("[渲染轮询] 开始轮询渲染作业状态"); @@ -125,7 +125,8 @@ public class RenderJobPollingService { jobStatus = renderJobService.getJobStatus(renderJobId); } catch (Exception e) { log.warn("[渲染轮询] 查询作业状态失败, renderJobId: {}, error: {}", renderJobId, e.getMessage()); - mappingMapper.incrementRetryCount(mapping.getId()); + // 注:此处不调用incrementRetryCount,因为@Transactional会回滚 + // 外层handleProcessError会负责增加重试次数 throw e; }