Skip to content

Commit 20f26df

Browse files
committed
added spotless check fixes
1 parent 5057b9a commit 20f26df

1 file changed

Lines changed: 15 additions & 16 deletions

File tree

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

Lines changed: 15 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -274,22 +274,21 @@ private void initApplicationSpanIfNotInitialized() {
274274
}
275275
}
276276

277-
captureApplicationParameters(builder);
278-
captureEmrStepId(builder);
279-
280-
Optional<OpenlineageParentContext> openlineageParentContext =
281-
OpenlineageParentContext.from(sparkConf);
282-
// We know we're not in Databricks context
283-
if (openlineageParentContext.isPresent()) {
284-
captureOpenlineageContextIfPresent(builder, openlineageParentContext.get());
285-
} else {
286-
builder.asChildOf(predeterminedTraceIdContext);
287-
}
288-
289-
applicationSpan = builder.start();
290-
setDataJobsSamplingPriority(applicationSpan);
291-
applicationSpan.setMeasured(true);
277+
captureApplicationParameters(builder);
278+
captureEmrStepId(builder);
279+
280+
Optional<OpenlineageParentContext> openlineageParentContext =
281+
OpenlineageParentContext.from(sparkConf);
282+
// We know we're not in Databricks context
283+
if (openlineageParentContext.isPresent()) {
284+
captureOpenlineageContextIfPresent(builder, openlineageParentContext.get());
285+
} else {
286+
builder.asChildOf(predeterminedTraceIdContext);
287+
}
292288

289+
applicationSpan = builder.start();
290+
setDataJobsSamplingPriority(applicationSpan);
291+
applicationSpan.setMeasured(true);
293292
}
294293

295294
private void captureOpenlineageContextIfPresent(
@@ -324,7 +323,7 @@ public synchronized void finishApplication(
324323
long time, Throwable throwable, int exitCode, String msg) {
325324
log.info("Finishing spark application trace");
326325

327-
if(applicationEnded){
326+
if (applicationEnded) {
328327
return;
329328
}
330329
applicationEnded = true;

0 commit comments

Comments
 (0)