[INLONG-11455][Sort] Append the install/uninstall logs by the specifi…

…ed log level
apache · Nov 10, 2024 · c937edc · c937edc
1 parent 8af51b9
commit c937edc
Showing 1 changed file with 12 additions and 2 deletions.
diff --git a/...t/sort-flink/base/src/main/java/org/apache/inlong/sort/base/util/OpenTelemetryLogger.java b/...t/sort-flink/base/src/main/java/org/apache/inlong/sort/base/util/OpenTelemetryLogger.java
@@ -33,7 +33,9 @@
 import org.apache.logging.log4j.core.LoggerContext;
 import org.apache.logging.log4j.core.config.Configuration;
 import org.apache.logging.log4j.core.config.LoggerConfig;
+import org.apache.logging.log4j.core.impl.Log4jLogEvent;
 import org.apache.logging.log4j.core.layout.PatternLayout;
+import org.apache.logging.log4j.message.SimpleMessage;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -209,7 +211,11 @@ public boolean install() {
             createOpenTelemetrySdk();
             // install OpenTelemetryAppender
             OpenTelemetryAppender.install(SDK);
-            LOG.info("OpenTelemetryLogger installed");
+            otelAppender.append(
+                    new Log4jLogEvent.Builder()
+                            .setLevel(this.logLevel)
+                            .setMessage(new SimpleMessage("OpenTelemetryLogger installed"))
+                            .build());
             return true;
         }
     }
@@ -232,7 +238,11 @@ public boolean uninstall() {
             Configuration config = loggerContext.getConfiguration();
             config.getAppenders().values().forEach(appender -> {
                 if (appender instanceof OpenTelemetryAppender) {
-                    LOG.info("Uninstall OpenTelemetryLogger");
+                    appender.append(
+                            new Log4jLogEvent.Builder()
+                                    .setLevel(this.logLevel)
+                                    .setMessage(new SimpleMessage("OpenTelemetryLogger uninstalled"))
+                                    .build());
                     config.getRootLogger().removeAppender(appender.getName());
                     appender.stop();
                 }