Added a bit more logs

kr-igor · kr-igor · commit 6346d74379be · 2024-08-19T15:51:59.000-05:00
diff --git a/dd-java-agent/instrumentation/spark/src/main/java/datadog/trace/instrumentation/spark/AbstractDatadogSparkListener.java b/dd-java-agent/instrumentation/spark/src/main/java/datadog/trace/instrumentation/spark/AbstractDatadogSparkListener.java
@@ -1209,6 +1209,7 @@ private static void reportKafkaOffsets(
 
             // for debug only, will be removed
             span.setTag("dsm." + topic + "." + partition, value);
+            span.setTag("dsm.app_name", appName);
           }
         }
       } catch (Exception e) {

Original file line number	Diff line number	Diff line change
`@@ -1209,6 +1209,7 @@ private static void reportKafkaOffsets(`
`1209`	`1209`
`1210`	`1210`	`// for debug only, will be removed`
`1211`	`1211`	`span.setTag("dsm." + topic + "." + partition, value);`
	`1212`	`+ span.setTag("dsm.app_name", appName);`
`1212`	`1213`	`}`
`1213`	`1214`	`}`
`1214`	`1215`	`} catch (Exception e) {`