diff --git a/fe/fe-core/src/main/java/org/apache/doris/binlog/BinlogUtils.java b/fe/fe-core/src/main/java/org/apache/doris/binlog/BinlogUtils.java index 3af4053ef1..30cbfd0e15 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/binlog/BinlogUtils.java +++ b/fe/fe-core/src/main/java/org/apache/doris/binlog/BinlogUtils.java @@ -119,6 +119,10 @@ public class BinlogUtils { public static long getExpiredMs(long ttlSeconds) { long currentSeconds = System.currentTimeMillis() / 1000; + if (currentSeconds < ttlSeconds) { + return Long.MIN_VALUE; + } + long expireSeconds = currentSeconds - ttlSeconds; return expireSeconds * 1000; }