updating to get rid of wrong spark spans

larakulkarni1 · larakulkarni1 · commit 1189586e428e · 2026-02-24T11:26:28.000-05:00
diff --git a/dd-java-agent/instrumentation/spark/spark-common/src/main/java/datadog/trace/instrumentation/spark/AbstractDatadogSparkListener.java b/dd-java-agent/instrumentation/spark/spark-common/src/main/java/datadog/trace/instrumentation/spark/AbstractDatadogSparkListener.java
@@ -254,7 +254,7 @@ private void initApplicationSpanIfNotInitialized() {
     }
 
     log.debug("Starting tracer application span.");
-
+    if(!isRunningOnDatabricks){
     AgentTracer.SpanBuilder builder = buildSparkSpan("spark.application", null);
 
     if (applicationStart != null) {
@@ -289,6 +289,7 @@ private void initApplicationSpanIfNotInitialized() {
     applicationSpan = builder.start();
     setDataJobsSamplingPriority(applicationSpan);
     applicationSpan.setMeasured(true);
+    }
   }
 
   private void captureOpenlineageContextIfPresent(

Original file line number	Diff line number	Diff line change
`@@ -254,7 +254,7 @@ private void initApplicationSpanIfNotInitialized() {`
`254`	`254`	`}`
`255`	`255`
`256`	`256`	`log.debug("Starting tracer application span.");`
`257`		`-`
	`257`	`+ if(!isRunningOnDatabricks){`
`258`	`258`	`AgentTracer.SpanBuilder builder = buildSparkSpan("spark.application", null);`
`259`	`259`
`260`	`260`	`if (applicationStart != null) {`
`@@ -289,6 +289,7 @@ private void initApplicationSpanIfNotInitialized() {`
`289`	`289`	`applicationSpan = builder.start();`
`290`	`290`	`setDataJobsSamplingPriority(applicationSpan);`
`291`	`291`	`applicationSpan.setMeasured(true);`
	`292`	`+ }`
`292`	`293`	`}`
`293`	`294`
`294`	`295`	`private void captureOpenlineageContextIfPresent(`