fix

dataroaring · Jun 21, 2024 · b61ecf4 · b61ecf4
1 parent 661a273
commit b61ecf4
Showing 1 changed file with 2 additions and 2 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
@@ -39,7 +39,6 @@
 import org.apache.doris.common.PatternMatcher;
 import org.apache.doris.common.PatternMatcherWrapper;
 import org.apache.doris.common.UserException;
-import org.apache.doris.common.io.Text;
 import org.apache.doris.common.io.Writable;
 import org.apache.doris.common.util.LogBuilder;
 import org.apache.doris.common.util.LogKey;
@@ -948,10 +947,11 @@ public void write(DataOutput out) throws IOException {
     public void readFields(DataInput in) throws IOException {
         long currentTimeMs = System.currentTimeMillis();
         int size = in.readInt();
-        LOG.info("string {}", Text.readString(in));
+        LOG.info("size {} ", 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;
             }