third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor: optimize worker log

Browse Source
This commit is contained in:
tjq 2024-08-11 01:12:56 +08:00
parent 605497b36d
commit 0a1191572e
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
powerjob-worker/src/main/java/tech/powerjob/worker/core/tracker/task/heavy/FrequentTaskTracker.java
View File

@ -1,6 +1,5 @@
package tech.powerjob.worker.core.tracker.task.heavy; package tech.powerjob.worker.core.tracker.task.heavy;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.google.common.base.Stopwatch; import com.google.common.base.Stopwatch;
import com.google.common.collect.Lists; import com.google.common.collect.Lists;
import com.google.common.collect.Maps; import com.google.common.collect.Maps;
@ -411,8 +410,8 @@ public class FrequentTaskTracker extends HeavyTaskTracker {
log.debug("[FQTaskTracker-{}] alert config:{}", instanceId, req.getAlarmConfig()); log.debug("[FQTaskTracker-{}] alert config:{}", instanceId, req.getAlarmConfig());
AlarmConfig alarmConfig = JsonUtils.parseObject(req.getAlarmConfig(), AlarmConfig.class); AlarmConfig alarmConfig = JsonUtils.parseObject(req.getAlarmConfig(), AlarmConfig.class);
return new AlertManager(alarmConfig); return new AlertManager(alarmConfig);
} catch (JsonProcessingException ignore) { } catch (Exception e) {
// log.warn("[FQTaskTracker-{}] constructAlertManager failed, will use default config!", instanceId);
} }
} }
// 默认配置，失败一次就告警，沉默窗口 5 分钟 // 默认配置，失败一次就告警，沉默窗口 5 分钟