|
@@ -77,7 +77,7 @@ public class SyncExamRecordDataJobHandler {
|
|
|
|
|
|
batchNo++;
|
|
|
sumTodoSize += todoList.size();
|
|
|
- log.warn("TODO_LIST_3 shardTotal:{}, shardIndex:{}, sumTodoSize:{}, curTodoSize:{}, batchNo:{}, startId:{}",
|
|
|
+ log.warn("STEP_3 shardTotal:{}, shardIndex:{}, sumTodoSize:{}, curTodoSize:{}, batchNo:{}, startId:{}",
|
|
|
shardTotal, shardIndex, sumTodoSize, todoList.size(), batchNo, startId);
|
|
|
|
|
|
if (CollectionUtils.isEmpty(todoList)) {
|
|
@@ -98,10 +98,10 @@ public class SyncExamRecordDataJobHandler {
|
|
|
throw e;
|
|
|
} else if (e instanceof SequenceLockException) {
|
|
|
// 若锁问题,下次会继续执行
|
|
|
- log.warn("当前考试记录数据获取锁失败!examRecordDataId:{}, redisKey:{}", data.getId(), lockKey);
|
|
|
+ log.warn("当前任务获取锁失败!examRecordDataId:{}, redisKey:{}", data.getId(), lockKey);
|
|
|
} else {
|
|
|
// 若异常,下次会继续执行(需要排查原因)
|
|
|
- log.error("当前考试记录数据处理失败!examRecordDataId:{}, error:{}", data.getId(), e.getMessage(), e);
|
|
|
+ log.error("当前任务处理失败!examRecordDataId:{}, error:{}", data.getId(), e.getMessage());
|
|
|
}
|
|
|
} finally {
|
|
|
SequenceLockHelper.releaseLockSimple(lockKey);
|