From 40d6f8172b790babcaa9c85771f31ada8409be15 Mon Sep 17 00:00:00 2001
From: ljq-dmr <1366404872@qq.com>
Date: Thu, 1 Feb 2024 14:03:16 +0800
Subject: [PATCH] =?UTF-8?q?[fire-1109]=20spark=E5=BC=95=E6=93=8E=E8=A1=80?=
 =?UTF-8?q?=E7=BC=98=E8=8E=B7=E5=8F=96active=20executor=E5=8F=AF=E8=83=BD?=
 =?UTF-8?q?=E5=AD=98=E5=9C=A8=E8=B4=9F=E6=95=B0=E7=9A=84=E6=83=85=E5=86=B5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../scala/com/zto/fire/spark/sync/DistributeSyncManager.scala   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/fire-engines/fire-spark/src/main/scala/com/zto/fire/spark/sync/DistributeSyncManager.scala b/fire-engines/fire-spark/src/main/scala/com/zto/fire/spark/sync/DistributeSyncManager.scala
index 0d8e7fa..cf7fcd4 100644
--- a/fire-engines/fire-spark/src/main/scala/com/zto/fire/spark/sync/DistributeSyncManager.scala
+++ b/fire-engines/fire-spark/src/main/scala/com/zto/fire/spark/sync/DistributeSyncManager.scala
@@ -37,7 +37,7 @@ object DistributeSyncManager extends SyncManager {
    * 获取当前任务的executor数
    */
   private[fire] def getInitExecutors: Int = {
-    if (SparkSingletonFactory.executorActiveCount.get() == 0) {
+    if (SparkSingletonFactory.executorActiveCount.get() <= 0) {
       this.sc.getConf.get("spark.executor.instances", if (OSUtils.isLinux) "100" else "10").toInt
     } else {
       SparkSingletonFactory.executorActiveCount.get()
-- 
Gitee