in spark-operator/src/main/java/org/apache/spark/k8s/operator/utils/LoggingUtils.java [37:50]
public void set(final SparkApplication application) {
if (application != null && application.getStatus() != null) {
try {
lock.lock();
ApplicationAttemptSummary summary = application.getStatus().getCurrentAttemptSummary();
if (summary != null && summary.getAttemptInfo() != null) {
MDC.put(AppAttemptIdKey, String.valueOf(summary.getAttemptInfo().getId()));
keys.add(AppAttemptIdKey);
}
} finally {
lock.unlock();
}
}
}