lanyuanxiaoyao/hudi-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor(launcher): 增加Clear hodler时的日志

Browse Source
This commit is contained in:
v-zhangjc9
2024-04-26 11:53:04 +08:00
parent e25b263843
commit d899556bfd
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
service-launcher/src/main/java/com/lanyuanxiaoyao/service/launcher/compaction/service/CompactionService.java
View File

@@ -229,9 +229,11 @@ public class CompactionService {
if (holder.isEmpty()) { if (holder.isEmpty()) {
return; return;
} }
logger.info("Clear holder, size: {}", holder.size());
// 等待半分钟 // 等待半分钟
ThreadUtil.safeSleep(Constants.HALF_MINUTE); ThreadUtil.safeSleep(Constants.HALF_MINUTE);
for (QueueItem<ScheduleJob> item : holder) { for (QueueItem<ScheduleJob> item : holder) {
logger.info("Push task to pre {}", item);
QueueUtil.add(discoveryClient, this.mapper, Constants.COMPACTION_QUEUE_PRE, item); QueueUtil.add(discoveryClient, this.mapper, Constants.COMPACTION_QUEUE_PRE, item);
} }
holder.clear(); holder.clear();