[fix](binlog) Fix BinlogUtils getExpiredMs overflow (#22174)

2023-07-26 15:15:34 +08:00
parent 6c0c66e664
commit af20d0c521
1 changed files with 4 additions and 0 deletions
--- 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;
    }