fix

dataroaring · Jun 21, 2024 · c115a6e · c115a6e
1 parent 06be42a
commit c115a6e
Showing 1 changed file with 2 additions and 0 deletions.
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
@@ -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);
         }
     }