Skip to content

Commit c02607d

Browse files
committed
error type and error message
1 parent f57bf18 commit c02607d

2 files changed

Lines changed: 6 additions & 4 deletions

File tree

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

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -111,14 +111,15 @@ public static synchronized void createLauncherSpan(Object launcher) {
111111
}
112112
}
113113

114-
public static synchronized void finishSpan(boolean isError, String errorType) {
114+
public static synchronized void finishSpan(boolean isError, String errorMessage) {
115115
AgentSpan span = launcherSpan;
116116
if (span == null) {
117117
return;
118118
}
119119
if (isError) {
120120
span.setError(true);
121-
span.setTag(DDTags.ERROR_TYPE, errorType);
121+
span.setTag(DDTags.ERROR_TYPE, "Spark Launcher Failed");
122+
span.setTag(DDTags.ERROR_MSG, errorMessage);
122123
}
123124
span.finish();
124125
launcherSpan = null;
@@ -176,7 +177,7 @@ public void stateChanged(SparkAppHandle handle) {
176177
if (state == SparkAppHandle.State.FAILED
177178
|| state == SparkAppHandle.State.KILLED
178179
|| state == SparkAppHandle.State.LOST) {
179-
finishSpan(true, "Spark Application " + state);
180+
finishSpan(true, "Application " + state);
180181
} else {
181182
finishSpan(false, null);
182183
}

dd-java-agent/instrumentation/spark/spark-common/src/test/groovy/datadog/trace/instrumentation/spark/SparkLauncherTest.groovy

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -160,7 +160,8 @@ class SparkLauncherTest extends InstrumentationSpecification {
160160
operationName "spark.launcher.launch"
161161
spanType "spark"
162162
errored true
163-
assert span.tags["error.type"] == "Spark Application FAILED"
163+
assert span.tags["error.type"] == "Spark Launcher Failed"
164+
assert span.tags["error.msg"] == "Application FAILED"
164165
assert span.tags["spark.app_id"] == "app-456"
165166
}
166167
}

0 commit comments

Comments
 (0)