执行器回调日志落盘方案复用RPC序列化方案,并移除Jackson依赖;

pull/8/MERGE
xuxueli 6 years ago
parent 14555f674c
commit 80b544b50a

@ -1461,6 +1461,7 @@ Tips: 历史版本(V1.3.x)目前已经Release至稳定版本, 进入维护阶段
- 31、调度中心-执行器通讯模型统一双向RPC切换为Netty - 31、调度中心-执行器通讯模型统一双向RPC切换为Netty
- 32、任务暂停、删除优化避免quartz delete不完整导致任务脏数据 - 32、任务暂停、删除优化避免quartz delete不完整导致任务脏数据
- 32、quartz misfire 配置优化计划改为0 - 32、quartz misfire 配置优化计划改为0
- 33、新增状态列支持筛选

@ -189,7 +189,7 @@ public class TriggerCallbackThread {
// ---------------------- fail-callback file ---------------------- // ---------------------- fail-callback file ----------------------
private static String failCallbackFilePath = XxlJobFileAppender.getLogPath().concat(File.separator).concat("callbacklog"); private static String failCallbackFilePath = XxlJobFileAppender.getLogPath().concat(File.separator).concat("callbacklog").concat(File.separator);
private static String failCallbackFileName = failCallbackFilePath.concat("xxl-job-callback-{x}").concat(".log"); private static String failCallbackFileName = failCallbackFilePath.concat("xxl-job-callback-{x}").concat(".log");
private void appendFailCallbackFile(List<HandleCallbackParam> callbackParamList){ private void appendFailCallbackFile(List<HandleCallbackParam> callbackParamList){

@ -52,12 +52,7 @@ public class FileUtil {
// file // file
if (!file.exists()) { if (!file.exists()) {
try { file.getParentFile().mkdirs();
file.createNewFile();
} catch (IOException e) {
logger.error(e.getMessage(), e);
return;
}
} }
// append file content // append file content

Loading…
Cancel
Save