Skip to content

Commit 06d44cd

Browse files
committed
removed logs
1 parent 2efadac commit 06d44cd

1 file changed

Lines changed: 2 additions & 22 deletions

File tree

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

Lines changed: 2 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -253,12 +253,11 @@ public synchronized void onApplicationStart(SparkListenerApplicationStart applic
253253
}
254254

255255
private void initApplicationSpanIfNotInitialized() {
256-
if (applicationSpan != null) {
256+
if (applicationSpan != null || isRunningOnDatabricks) {
257257
return;
258258
}
259259

260260
log.debug("Starting tracer application span.");
261-
if (!isRunningOnDatabricks) {
262261
AgentTracer.SpanBuilder builder = buildSparkSpan("spark.application", null);
263262

264263
if (applicationStart != null) {
@@ -294,7 +293,7 @@ private void initApplicationSpanIfNotInitialized() {
294293
applicationSpan = builder.start();
295294
setDataJobsSamplingPriority(applicationSpan);
296295
applicationSpan.setMeasured(true);
297-
}
296+
298297
}
299298

300299
private void captureOpenlineageContextIfPresent(
@@ -331,25 +330,8 @@ public void onApplicationEnd(SparkListenerApplicationEnd applicationEnd) {
331330
public synchronized void finishApplication(
332331
long time, Throwable throwable, int exitCode, String msg) {
333332
log.info("Finishing spark application trace");
334-
335-
if (applicationEnded) {
336-
log.info(
337-
"finishApplicationEnded: isRunningOnDatabricks={}, databricksClusterName={}, applicationSpan={}, jobCount={}",
338-
isRunningOnDatabricks,
339-
databricksClusterName,
340-
applicationSpan != null ? "exists" : "null",
341-
jobCount);
342-
return;
343-
}
344333
applicationEnded = true;
345334

346-
log.info(
347-
"finishApplication: isRunningOnDatabricks={}, databricksClusterName={}, applicationSpan={}, jobCount={}",
348-
isRunningOnDatabricks,
349-
databricksClusterName,
350-
applicationSpan != null ? "exists" : "null",
351-
jobCount);
352-
353335
if (applicationSpan == null && jobCount > 0) {
354336
// If the application span is not initialized, but spark jobs have been executed, all those
355337
// spark jobs were databricks or streaming. In this case we don't send the application span
@@ -360,8 +342,6 @@ public synchronized void finishApplication(
360342
if (applicationSpan == null) {
361343
// On Databricks or streaming environments, the application span is not created.
362344
// Flush any remaining traces and return.
363-
log.info(
364-
"No application span created, skipping. isRunningOnDatabricks={}", isRunningOnDatabricks);
365345
tracer.flush();
366346
return;
367347
}

0 commit comments

Comments
 (0)