diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadManager.java b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadManager.java index 9d7c0f3bc778378..a228c898f7b58b5 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadManager.java +++ b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadManager.java @@ -933,8 +933,10 @@ public void write(DataOutput out) throws IOException { idToLoadJob.values().stream().filter(t -> !t.isExpired(currentTimeMs)) .filter(t -> !(t instanceof MiniLoadJob)).collect(Collectors.toList()); + LOG.info("write load job size: {}", loadJobs.size()); out.writeInt(loadJobs.size()); for (LoadJob loadJob : loadJobs) { + LOG.info("write load job: {}", loadJob.getId()); loadJob.write(out); } }