|
@@ -79,7 +79,7 @@ public class ClearExpireDataJobHandler {
|
|
|
}
|
|
|
countSql.append(" and creation_time <= '").append(expireTime).append("'");
|
|
|
Long totalCount = jdbcTemplate.queryForObject(countSql.toString(), Long.class);
|
|
|
- log.warn("清理过期数据任务!jobParam:{} expireTime:{} totalSize:{}", jobParam, expireTime, totalCount);
|
|
|
+ log.warn("清理过期数据任务!jobParam:{} totalCount:{} [{}]", jobParam, totalCount, countSql);
|
|
|
if (totalCount == null || totalCount == 0) {
|
|
|
return;
|
|
|
}
|
|
@@ -107,7 +107,7 @@ public class ClearExpireDataJobHandler {
|
|
|
finishCount += tempIds.size();
|
|
|
float finishRate = finishCount * 100f / totalCount;
|
|
|
long cost = (System.currentTimeMillis() - startTime) / 1000L;
|
|
|
- log.warn("totalSize:{} finishCount:{} finishRate:{}% startId:{} cost:{}s", totalCount, finishCount, finishRate, startId, cost);
|
|
|
+ log.warn("totalCount:{} finishCount:{} finishRate:{}% startId:{} cost:{}s", totalCount, finishCount, finishRate, startId, cost);
|
|
|
startId = tempIds.get(tempIds.size() - 1);
|
|
|
}
|
|
|
}
|