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 0d8e7fa2401c2227f59e7df7929cf3e5087dd940..cf7fcd4e6b3ee6acd05af521fb278169fb25aee3 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()