diff --git a/inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/util/OpenTelemetryLogger.java b/inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/util/OpenTelemetryLogger.java index c6366845cf..12b1cf558a 100644 --- a/inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/util/OpenTelemetryLogger.java +++ b/inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/util/OpenTelemetryLogger.java @@ -182,7 +182,7 @@ public boolean install() { synchronized (OpenTelemetryLogger.class) { org.apache.logging.log4j.spi.LoggerContext loggerContextSpi = LogManager.getContext(false); if (!(loggerContextSpi instanceof LoggerContext)) { - LOG.warn("LoggerContext is not instance of LoggerContext"); + LOG.warn("LoggerContext is not instance of org.apache.logging.log4j.core.LoggerContext"); return false; } LoggerContext loggerContext = (LoggerContext) loggerContextSpi; @@ -231,7 +231,7 @@ public boolean uninstall() { } org.apache.logging.log4j.spi.LoggerContext loggerContextSpi = LogManager.getContext(false); if (!(loggerContextSpi instanceof LoggerContext)) { - LOG.warn("LoggerContext is not instance of LoggerContext"); + LOG.warn("LoggerContext is not instance of org.apache.logging.log4j.core.LoggerContext"); return false; } LoggerContext loggerContext = (LoggerContext) loggerContextSpi;