File tree 3 files changed +17
-6
lines changed
dd-java-agent/instrumentation
spark/src/testFixtures/groovy/datadog/trace/instrumentation/spark
3 files changed +17
-6
lines changed Original file line number Diff line number Diff line change @@ -167,8 +167,7 @@ commands:
167
167
if [[ "$BRANCH" != "master" ]] && [[ "$BRANCH" != "release/*" ]]; then
168
168
# We know that we have checked out the PR merge branch, so the HEAD commit is a merge
169
169
# As a backup, if anything goes wrong with the diff, the build will fail
170
- # Get list of changed files directly using git diff-tree to avoid issues with large binary files
171
- CHANGED_FILES=$(git diff-tree --no-commit-id --name-only -r HEAD)
170
+ CHANGED_FILES=$(git show HEAD | grep -e "^Merge:" | cut -d ' ' -f 2- | sed 's/ /.../' | xargs git diff --name-only)
172
171
# Count the number of matches, and ignore if the grep doesn't match anything
173
172
MATCH_COUNT=$(echo "$CHANGED_FILES" | grep -c -E "<< pipeline.parameters.global_pattern >>|<< parameters.pattern >>") || true
174
173
if [[ "$MATCH_COUNT" -eq "0" ]]; then
Original file line number Diff line number Diff line change @@ -78,6 +78,9 @@ configurations.all {
78
78
// avoid bringing in logback based on java 11
79
79
force libs. logback. classic
80
80
force libs. logback. core
81
+
82
+ // force specific version of byte-buddy for all configurations
83
+ force ' net.bytebuddy:byte-buddy:1.14.18'
81
84
}
82
85
}
83
86
@@ -146,7 +149,6 @@ dependencies {
146
149
testImplementation project(' :dd-java-agent:instrumentation:caffeine' )
147
150
testImplementation project(' :dd-java-agent:instrumentation:quartz-2' )
148
151
149
-
150
152
testImplementation group : ' org.mule.runtime' , name : ' mule-module-launcher' , version : muleVersion
151
153
testImplementation group : ' org.mule.runtime' , name : ' mule-core' , version : muleVersion
152
154
// testImplementation group: 'org.mule.runtime', name: 'mule-module-extensions-spring-support', version: muleVersion
@@ -175,7 +177,6 @@ dependencies {
175
177
latestDepForkedTestImplementation group : ' org.mule.runtime' , name : ' mule-module-service' , version : ' 4.8.+'
176
178
latestDepForkedTestImplementation group : ' org.mule.runtime' , name : ' mule-module-javaee' , version : ' 4.8.+'
177
179
178
-
179
180
// TODO: 4.9.0 is not yet out but it looks like using 4.+ instead of above 4.8.+ brings in 4.9.0-SNAPSHOT artifacts.
180
181
/*
181
182
When testing with them, the mule container does not bootstrap because of:
Original file line number Diff line number Diff line change @@ -475,9 +475,20 @@ abstract class AbstractSparkListenerTest extends AgentTestRunner {
475
475
conf. set(" spark.openlineage.rootParentJobName" , " dag-push-to-s3-spark" )
476
476
def listener = getTestDatadogSparkListener(conf)
477
477
478
- expect :
478
+ when :
479
479
listener. onApplicationStart(applicationStartEvent(1000L ))
480
- assert listener. openLineageSparkConf. get(" spark.openlineage.run.tags" ). contains(" 13959090542865903119" )
480
+ listener. onApplicationEnd(new SparkListenerApplicationEnd (2000L ))
481
+
482
+ then :
483
+ assertTraces(1 ) {
484
+ trace(1 ) {
485
+ span {
486
+ operationName " spark.application"
487
+ spanType " spark"
488
+ assert span. context. traceId. toString() == " 13959090542865903119"
489
+ }
490
+ }
491
+ }
481
492
}
482
493
483
494
def " test lastJobFailed is not set when job is cancelled" () {
You can’t perform that action at this time.
0 commit comments