feat: 3.2.0
1. 修复mysql ddl 错误
This commit is contained in:
parent
35a86e133b
commit
2f9d40b445
@ -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`)
|
||||
|
@ -104,7 +104,7 @@ public class RetrySummarySchedule extends AbstractSchedule implements Lifecycle
|
||||
|
||||
List<RetrySummary> waitInserts = Lists.newArrayList();
|
||||
List<RetrySummary> 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 {
|
||||
|
Loading…
Reference in New Issue
Block a user