From 03e920d3fb2c49b407479b2c89f6bbe52bca37d3 Mon Sep 17 00:00:00 2001 From: Yongqiang YANG Date: Fri, 21 Jun 2024 12:06:28 +0800 Subject: [PATCH] fix --- .../src/main/java/org/apache/doris/load/loadv2/LoadJob.java | 2 -- .../main/java/org/apache/doris/load/loadv2/LoadManager.java | 3 +-- 2 files changed, 1 insertion(+), 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 index 6563b2f99b79f06..eef8b5d40711e46 100644 --- 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 index 9d14b487a0da5ac..1026689d8f1448f 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 @@ -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; }