fix

dataroaring · Jun 21, 2024 · c4aecaf · c4aecaf
1 parent b61ecf4
commit c4aecaf
Showing 1 changed file with 2 additions and 0 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,6 +1218,8 @@ 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;
     }