Skip to content

Commit 09ebd0e

Browse files
committed
[DJM-0000] Debug Databricks
1 parent 6d2b809 commit 09ebd0e

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

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

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1085,13 +1085,15 @@ private long stageSpanKey(int stageId, int attemptId) {
10851085
@SuppressForbidden // split with one-char String use a fast-path without regex usage
10861086
private static String getDatabricksJobId(Properties properties) {
10871087
String jobId = properties.getProperty("spark.databricks.job.id");
1088+
log.error("[CHARLES] getDatabricksJobId spark.databricks.job.id: '{}'", jobId);
10881089
if (jobId != null) {
10891090
return jobId;
10901091
}
10911092

10921093
// First fallback, use spark.jobGroup.id with the pattern
10931094
// <scheduler_id>_job-<job_id>-run-<task_run_id>-action-<action_id>
10941095
String jobGroupId = properties.getProperty("spark.jobGroup.id");
1096+
log.error("[CHARLES] getDatabricksJobId spark.jobGroup.id: '{}'", jobGroupId);
10951097
if (jobGroupId != null) {
10961098
int startIndex = jobGroupId.indexOf("job-");
10971099
int endIndex = jobGroupId.indexOf("-run", startIndex);
@@ -1103,6 +1105,7 @@ private static String getDatabricksJobId(Properties properties) {
11031105
// Second fallback, use spark.databricks.workload.id with pattern
11041106
// <org_id>-<job_id>-<task_run_id>
11051107
String workloadId = properties.getProperty("spark.databricks.workload.id");
1108+
log.error("[CHARLES] getDatabricksJobId spark.databricks.workload.id: '{}'", workloadId);
11061109
if (workloadId != null) {
11071110
String[] parts = workloadId.split("-");
11081111
if (parts.length > 1) {

0 commit comments

Comments
 (0)