From 3d49195901c1f6f4a7f13c519a14e55da4bb8a34 Mon Sep 17 00:00:00 2001 From: fornaix Date: Fri, 8 Sep 2023 18:17:41 +0800 Subject: [PATCH] no need to wait after a successful retry --- .../src/main/scala/org/apache/doris/spark/sql/Utils.scala | 1 - 1 file changed, 1 deletion(-) diff --git a/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/Utils.scala b/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/Utils.scala index 54976a7d..4d70e1e5 100644 --- a/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/Utils.scala +++ b/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/Utils.scala @@ -176,7 +176,6 @@ private[spark] object Utils { val result = Try(f) result match { case Success(result) => - LockSupport.parkNanos(interval.toNanos) Success(result) case Failure(exception: T) if retryTimes > 0 => logger.warn(s"Execution failed caused by: ", exception)