Skip to content

Commit 01be608

Browse files
committed
Update AbstractDatadogSparkListener.java
1 parent 26d436a commit 01be608

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1181,7 +1181,8 @@ private static String getDatabricksTaskRunId(Properties properties, String jobRu
11811181
// spark.databricks.job.runId is the runId of the task, not of the Job, until Databricks 18.2
11821182
String taskRunId = properties.getProperty("spark.databricks.job.runId");
11831183
// On Databricks 18.2+, spark.databricks.job.runId now returns the job run ID
1184-
// There is no easy config key to extract the task run ID, so we use the fallback extraction methods
1184+
// There is no easy config key to extract the task run ID, so we use the fallback extraction
1185+
// methods
11851186
// Task run ID is crucial for the spans parent-child relationship inside the trace
11861187
if (taskRunId != null && !taskRunId.equals(jobRunId)) {
11871188
return taskRunId;

0 commit comments

Comments
 (0)