From 2f9d40b445e396f8f29a89b12a62ac27f633dea0 Mon Sep 17 00:00:00 2001 From: byteblogs168 <598092184@qq.com> Date: Tue, 2 Apr 2024 23:11:10 +0800 Subject: [PATCH] =?UTF-8?q?feat:=203.2.0=201.=20=E4=BF=AE=E5=A4=8Dmysql=20?= =?UTF-8?q?ddl=20=E9=94=99=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- doc/sql/easy_retry_mysql.sql | 2 +- .../retry/task/support/schedule/RetrySummarySchedule.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/doc/sql/easy_retry_mysql.sql b/doc/sql/easy_retry_mysql.sql index bf2d52371..6ace09e0a 100644 --- a/doc/sql/easy_retry_mysql.sql +++ b/doc/sql/easy_retry_mysql.sql @@ -161,7 +161,7 @@ CREATE TABLE `retry_task_log_message` `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `message` longtext NOT NULL COMMENT '异常信息', `log_num` int(11) NOT NULL DEFAULT 1 COMMENT '日志数量', - `real_time` bigint(13) NOT NULL DEFAULT 0 COMMENT '上报时间' + `real_time` bigint(13) NOT NULL DEFAULT 0 COMMENT '上报时间', PRIMARY KEY (`id`), KEY `idx_namespace_id_group_name_scene_name` (`namespace_id`, `group_name`, `unique_id`), KEY `idx_create_dt` (`create_dt`) diff --git a/easy-retry-server/easy-retry-server-retry-task/src/main/java/com/aizuda/easy/retry/server/retry/task/support/schedule/RetrySummarySchedule.java b/easy-retry-server/easy-retry-server-retry-task/src/main/java/com/aizuda/easy/retry/server/retry/task/support/schedule/RetrySummarySchedule.java index dcb13a1b2..28b6b0ee6 100644 --- a/easy-retry-server/easy-retry-server-retry-task/src/main/java/com/aizuda/easy/retry/server/retry/task/support/schedule/RetrySummarySchedule.java +++ b/easy-retry-server/easy-retry-server-retry-task/src/main/java/com/aizuda/easy/retry/server/retry/task/support/schedule/RetrySummarySchedule.java @@ -104,7 +104,7 @@ public class RetrySummarySchedule extends AbstractSchedule implements Lifecycle List waitInserts = Lists.newArrayList(); List waitUpdates = Lists.newArrayList(); - for (final RetrySummary retrySummary : retrySummaries) { + for (final RetrySummary retrySummary : retrySummaryList) { if (Objects.isNull(summaryMap.get(Triple.of(mergeKey(retrySummary), retrySummary.getSceneName(), retrySummary.getTriggerAt())))) { waitInserts.add(retrySummary); } else {