Skip to content

Commit 68ebce2

Browse files
committed
Restore SparkSqlFailureAdvice.enter SQL text logging
1 parent 66cec29 commit 68ebce2

1 file changed

Lines changed: 13 additions & 0 deletions

File tree

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

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -142,6 +142,19 @@ public static void enter(@Advice.Argument(1) int exitCode, @Advice.Argument(2) S
142142
}
143143

144144
public static class SparkSqlFailureAdvice {
145+
@Advice.OnMethodEnter(suppress = Throwable.class)
146+
public static void enter(@Advice.Argument(0) String sqlText) {
147+
System.err.println(
148+
"[DD-SPARK-DEBUG] SparkSqlFailureAdvice.enter: thread="
149+
+ Thread.currentThread().getName()
150+
+ ", sql="
151+
+ (sqlText != null && sqlText.length() > 200
152+
? sqlText.substring(0, 200) + "..."
153+
: sqlText)
154+
+ ", listenerNull="
155+
+ (AbstractDatadogSparkListener.listener == null));
156+
}
157+
145158
@Advice.OnMethodExit(suppress = Throwable.class, onThrowable = Throwable.class)
146159
public static void exit(@Advice.Thrown Throwable throwable) {
147160
if (throwable != null) {

0 commit comments

Comments
 (0)