Cast to Number type instead of Long

charlesmyu · charlesmyu · commit b203263f9756 · 2026-03-10T11:01:40.000-04:00
diff --git a/dd-java-agent/instrumentation/spark/spark-common/src/main/java/datadog/trace/instrumentation/spark/SparkAggregatedTaskMetrics.java b/dd-java-agent/instrumentation/spark/spark-common/src/main/java/datadog/trace/instrumentation/spark/SparkAggregatedTaskMetrics.java
@@ -157,7 +157,7 @@ public void addTaskMetrics(
                 try {
                   // As of spark 3.5, all SQL metrics are Long, safeguard if it changes in new
                   // versions
-                  hist.accept((Long) acc.value());
+                  hist.accept(((Number) acc.value()).doubleValue());
                   externalAccumulableHistograms.put(acc.id(), hist);
                 } catch (ClassCastException ignored) {
                 }

Original file line number	Diff line number	Diff line change
`@@ -157,7 +157,7 @@ public void addTaskMetrics(`
`157`	`157`	`try {`
`158`	`158`	`// As of spark 3.5, all SQL metrics are Long, safeguard if it changes in new`
`159`	`159`	`// versions`
`160`		`- hist.accept((Long) acc.value());`
	`160`	`+ hist.accept(((Number) acc.value()).doubleValue());`
`161`	`161`	`externalAccumulableHistograms.put(acc.id(), hist);`
`162`	`162`	`} catch (ClassCastException ignored) {`
`163`	`163`	`}`