Skip to content

Commit 449dd10

Browse files
committed
catch error end
1 parent bf99260 commit 449dd10

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

dd-java-agent/instrumentation/spark/spark-common/src/main/java/datadog/trace/instrumentation/spark/AbstractSparkInstrumentation.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -106,6 +106,12 @@ public static void exit(@Advice.Thrown Throwable throwable) {
106106
if (AbstractDatadogSparkListener.listener != null) {
107107
AbstractDatadogSparkListener.listener.finishApplication(
108108
System.currentTimeMillis(), throwable, 0, null);
109+
} else if (SparkLauncherAdvice.launcherSpan != null) {
110+
if (throwable != null) {
111+
SparkLauncherAdvice.launcherSpan.addThrowable(throwable);
112+
}
113+
SparkLauncherAdvice.launcherSpan.finish();
114+
SparkLauncherAdvice.launcherSpan = null;
109115
}
110116
}
111117
}

0 commit comments

Comments
 (0)