fix

dataroaring · Jun 21, 2024 · 03e920d · 03e920d
1 parent c4aecaf
commit 03e920d
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 4 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadJob.java b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadJob.java
@@ -1218,8 +1218,6 @@ public boolean isExpired(long currentTimeMs) {
         if (jobType == EtlJobType.INSERT) {
             expireTime = Config.streaming_label_keep_max_second;
         }
-        LOG.info("currentTimeMs: {}, finishTimestamp: {}, isCompleted: {}, expireTime: {}",
-                 currentTimeMs, getFinishTimestamp(), isCompleted(), expireTime);
 
         return (currentTimeMs - getFinishTimestamp()) / 1000 > expireTime;
     }

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
@@ -947,11 +947,10 @@ public void write(DataOutput out) throws IOException {
     public void readFields(DataInput in) throws IOException {
         long currentTimeMs = System.currentTimeMillis();
         int size = in.readInt();
-        LOG.info("size {} ", size);
+        LOG.info("load job num {} ", size);
         for (int i = 0; i < size; i++) {
             LoadJob loadJob = LoadJob.read(in);
             if (loadJob.isExpired(currentTimeMs)) {
-                LOG.info("job {} is expired, skip", loadJob.getId());
                 continue;
             }