From ad62bc8e5112c400516f76c1041a6fbff97fdb42 Mon Sep 17 00:00:00 2001
From: zhanggougou <15651908511@163.com>
Date: Fri, 7 Nov 2025 10:48:24 +0800
Subject: [PATCH] =?UTF-8?q?[fire-1258]=20spark3.0=E5=AE=8C=E5=96=84task=20?=
 =?UTF-8?q?failed=E6=A0=B9=E5=9B=A0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../scala/com/zto/fire/spark/listener/FireSparkListener.scala   | 2 ++
 1 file changed, 2 insertions(+)

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 4e0e2942..6d618f18 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}")
     }
   }
-- 
Gitee