File tree Expand file tree Collapse file tree 4 files changed +4
-4
lines changed
dd-java-agent/instrumentation
spark/src/main/java/datadog/trace/instrumentation/spark Expand file tree Collapse file tree 4 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -1002,7 +1002,7 @@ validate_supported_configurations_v2_local_file:
10021002 extends : .validate_supported_configurations_v2_local_file
10031003 variables :
10041004 LOCAL_JSON_PATH : " metadata/supported-configurations.json"
1005- BACKFILLED : " true "
1005+ BACKFILLED : " false "
10061006
10071007update_central_configurations_version_range_v2 :
10081008 extends : .update_central_configurations_version_range_v2
Original file line number Diff line number Diff line change 55 module = " redisson"
66 versions = " [3.10.3,)"
77 skipVersions + = " 0.9.0"
8+ skipVersions + = " 4.0.0" // FIXME: Temporary skip `4.0.0` as we need more time to support it.
89 assertInverse = true
910 }
1011}
Original file line number Diff line number Diff line change 5858import org .apache .spark .sql .execution .SQLExecution ;
5959import org .apache .spark .sql .execution .SparkPlanInfo ;
6060import org .apache .spark .sql .execution .metric .SQLMetricInfo ;
61- import org .apache .spark .sql .execution .streaming .StreamExecution ;
6261import org .apache .spark .sql .execution .ui .SparkListenerSQLExecutionEnd ;
6362import org .apache .spark .sql .execution .ui .SparkListenerSQLExecutionStart ;
6463import org .apache .spark .sql .streaming .SourceProgress ;
@@ -1264,7 +1263,7 @@ private static String getStreamingBatchKey(Properties properties) {
12641263 return null ;
12651264 }
12661265
1267- Object queryId = properties .get (StreamExecution . QUERY_ID_KEY () );
1266+ Object queryId = properties .get ("sql.streaming.queryId" );
12681267 Object batchId = properties .get ("streaming.sql.batchId" );
12691268
12701269 if (queryId == null || batchId == null ) {
Original file line number Diff line number Diff line change @@ -627,7 +627,7 @@ include(
627627)
628628
629629// Optional `akka-http-10.6` instrumentation (see BUILDING.md for how to enable it):
630- if (providers.gradleProperty(" akkaRepositoryToken" ).isPresent ) {
630+ if (providers.gradleProperty(" akkaRepositoryToken" ).getOrElse( " " ).isNotBlank() ) {
631631 include(
632632 " :dd-java-agent:instrumentation:akka:akka-http:akka-http-10.6"
633633 )
You can’t perform that action at this time.
0 commit comments