From 2518ed64ea12dfbe93c1d8abc18cca0fbe260389 Mon Sep 17 00:00:00 2001
From: Siyang Tang <82279870+TangSiyang2001@users.noreply.github.com>
Date: Fri, 29 Dec 2023 23:44:43 +0800
Subject: [PATCH] [enhancement](bulk-load) strict second level granularity for
 timeout between (0,1) (#29028)

---
 .../java/org/apache/doris/load/loadv2/LoadLoadingTask.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadLoadingTask.java b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadLoadingTask.java
index cbe293a8ab..a56ba1acd1 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadLoadingTask.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadLoadingTask.java
@@ -160,7 +160,8 @@ public class LoadLoadingTask extends LoadTask {
         if (leftTimeMs <= 0) {
             throw new LoadException("failed to execute loading task when timeout");
         }
-        int timeoutS = (int) (leftTimeMs / 1000);
+        // 1 second is the minimum granularity of actual execution
+        int timeoutS = Math.max((int) (leftTimeMs / 1000), 1);
         curCoordinator.setTimeout(timeoutS);
 
         try {