@@ -41,7 +41,7 @@ public class AfterHandInExamJobHandler {
batchNo++;
sumTodoSize += todoList.size();
- log.warn(" 分片任务_{}_{}_STEP2 sumTodoSize:{} curTodoSize:{} batchNo:{} startId:{}",
+ log.warn(" 分片任务_STEP2_{}_{} sumTodoSize:{} curTodoSize:{} batchNo:{} startId:{}",
shardTotal, shardIndex, sumTodoSize, todoList.size(), batchNo, startId);
if (CollectionUtils.isEmpty(todoList)) {
@@ -59,7 +59,7 @@ public class BeforeHandInExamJobHandler {
- log.warn(" 分片任务_{}_{}_STEP1 sumTodoSize:{} curTodoSize:{} batchNo:{} startId:{}",
+ log.warn(" 分片任务_STEP1_{}_{} sumTodoSize:{} curTodoSize:{} batchNo:{} startId:{}",
@@ -31,7 +31,7 @@ public class FaceVerifyJobHandler {
int batchSize = 100, maxErrorNum = 10;
List<Long> todoExamRecordDataIds = examCaptureQueueRepo.findQueuesGroupByExamRecordDataId(shardTotal, shardIndex, batchSize, maxErrorNum);
- log.warn("分片任务_{}_{} curTodoExamRecordDataIds_size:{}", shardTotal, shardIndex, todoExamRecordDataIds.size());
+ log.warn("分片任务_FACE_{}_{} curTodoExamRecordDataIds_size:{}", shardTotal, shardIndex, todoExamRecordDataIds.size());
if (CollectionUtils.isEmpty(todoExamRecordDataIds)) {
return;
}
@@ -79,7 +79,7 @@ public class SyncExamRecordDataJobHandler {
- log.warn("分片任务_{}_{}_STEP3 sumTodoSize:{} curTodoSize:{} batchNo:{} startId:{}",
+ log.warn("分片任务_STEP3_{}_{} sumTodoSize:{} curTodoSize:{} batchNo:{} startId:{}",