Spotless

charlesmyu · charlesmyu · commit 4c54b6b488d1 · 2026-03-10T17:58:34.000-04: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
@@ -676,7 +676,8 @@ public synchronized void onStageCompleted(SparkListenerStageCompleted stageCompl
 
     SparkPlanInfo sqlPlan = sqlPlans.get(sqlExecutionId);
     if (sqlPlan != null) {
-      SparkSQLUtils.addSQLPlanToStageSpan(span, sqlPlan, accumulatorToStageID, stageMetric, stageId);
+      SparkSQLUtils.addSQLPlanToStageSpan(
+          span, sqlPlan, accumulatorToStageID, stageMetric, stageId);
     }
 
     span.finish(completionTimeMs * 1000);
diff --git a/dd-java-agent/instrumentation/spark/spark-common/src/main/java/datadog/trace/instrumentation/spark/SparkSQLUtils.java b/dd-java-agent/instrumentation/spark/spark-common/src/main/java/datadog/trace/instrumentation/spark/SparkSQLUtils.java
@@ -88,7 +88,8 @@ public static SparkPlanInfoForStage computeStageInfoForStage(
     return null;
   }
 
-  private static Set<Integer> stageIdsForPlan(SparkPlanInfo info, Map<Long, Integer> accumulatorToStageID) {
+  private static Set<Integer> stageIdsForPlan(
+      SparkPlanInfo info, Map<Long, Integer> accumulatorToStageID) {
     Set<Integer> stageIds = new HashSet<>();
 
     Collection<SQLMetricInfo> metrics =

Original file line number	Diff line number	Diff line change
`@@ -676,7 +676,8 @@ public synchronized void onStageCompleted(SparkListenerStageCompleted stageCompl`
`676`	`676`
`677`	`677`	`SparkPlanInfo sqlPlan = sqlPlans.get(sqlExecutionId);`
`678`	`678`	`if (sqlPlan != null) {`
`679`		`- SparkSQLUtils.addSQLPlanToStageSpan(span, sqlPlan, accumulatorToStageID, stageMetric, stageId);`
	`679`	`+ SparkSQLUtils.addSQLPlanToStageSpan(`
	`680`	`+ span, sqlPlan, accumulatorToStageID, stageMetric, stageId);`
`680`	`681`	`}`
`681`	`682`
`682`	`683`	`span.finish(completionTimeMs * 1000);`
Original file line number	Diff line number	Diff line change
`@@ -88,7 +88,8 @@ public static SparkPlanInfoForStage computeStageInfoForStage(`
`88`	`88`	`return null;`
`89`	`89`	`}`
`90`	`90`
`91`		`- private static Set<Integer> stageIdsForPlan(SparkPlanInfo info, Map<Long, Integer> accumulatorToStageID) {`
	`91`	`+ private static Set<Integer> stageIdsForPlan(`
	`92`	`+ SparkPlanInfo info, Map<Long, Integer> accumulatorToStageID) {`
`92`	`93`	`Set<Integer> stageIds = new HashSet<>();`
`93`	`94`
`94`	`95`	`Collection<SQLMetricInfo> metrics =`