diff --git a/fire-engines/fire-spark/src/main/scala/com/zto/fire/spark/listener/FireSparkListener.scala b/fire-engines/fire-spark/src/main/scala/com/zto/fire/spark/listener/FireSparkListener.scala
index 4e0e29421c59eed3ceb6557645eb4e5ca3c6a6df..6d618f18021c44af9f503af28bdd1a9128a25c3a 100644
--- a/fire-engines/fire-spark/src/main/scala/com/zto/fire/spark/listener/FireSparkListener.scala
+++ b/fire-engines/fire-spark/src/main/scala/com/zto/fire/spark/listener/FireSparkListener.scala
@@ -180,6 +180,8 @@ private[fire] class FireSparkListener(baseSpark: BaseSpark) extends SparkListene
     } else {
       AccumulatorManager.addMultiTimer(module, "onTaskEnd", "onTaskEnd", "", "ERROR", "", 1)
       ErrorToleranceAcc.addTaskFailedCount()
+      // 异常信息统一投递到Fire异常总线
+      ExceptionBus.post(new FireSparkException(taskEnd.reason.toString))
       this.logError(s"task failed. reason: ${taskEnd.reason}")
     }
   }