Added a debug tag

kr-igor · kr-igor · commit d73762f4296f · 2024-08-19T14:50:40.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
@@ -1201,6 +1201,9 @@ private static void reportKafkaOffsets(
             AgentTracer.get()
                 .getDataStreamsMonitoring()
                 .trackBacklog(sortedTags, Long.parseLong(value));
+
+            // for debug only, will be removed
+            span.setTag("dsm." + partition, value);
           }
         }
       } catch (Exception e) {

Original file line number	Diff line number	Diff line change
`@@ -1201,6 +1201,9 @@ private static void reportKafkaOffsets(`
`1201`	`1201`	`AgentTracer.get()`
`1202`	`1202`	`.getDataStreamsMonitoring()`
`1203`	`1203`	`.trackBacklog(sortedTags, Long.parseLong(value));`
	`1204`	`+`
	`1205`	`+ // for debug only, will be removed`
	`1206`	`+ span.setTag("dsm." + partition, value);`
`1204`	`1207`	`}`
`1205`	`1208`	`}`
`1206`	`1209`	`} catch (Exception e) {`