feat: use local logger instead of slf4j annotation which causes compi…

…le fail (#3894) * Use local logger instead of slf4j annotation which causes compile fail * Change log to logger in taskmanager server
4paradigm · Apr 25, 2024 · 29b1e0b · 29b1e0b
1 parent 357d45f
commit 29b1e0b
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/...-taskmanager/src/main/java/com/_4paradigm/openmldb/taskmanager/server/JobResultSaver.java b/...-taskmanager/src/main/java/com/_4paradigm/openmldb/taskmanager/server/JobResultSaver.java
@@ -25,6 +25,8 @@
 import org.apache.commons.csv.CSVRecord;
 import org.apache.commons.csv.QuoteMode;
 import org.apache.commons.io.FileUtils;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
 
 import java.io.BufferedReader;
 import java.io.File;
@@ -51,6 +53,8 @@
  */
 @Slf4j
 public class JobResultSaver {
+    private static final Log log = LogFactory.getLog(JobResultSaver.class);
+
     // false: unused, true: using
     // 0: unused, 1: saving, 2: finished but still in use
     private List<Integer> idStatus;

diff --git a/...skmanager/src/main/java/com/_4paradigm/openmldb/taskmanager/server/TaskManagerServer.java b/...skmanager/src/main/java/com/_4paradigm/openmldb/taskmanager/server/TaskManagerServer.java
@@ -105,8 +105,8 @@ public void startRpcServer(Boolean blocking) throws ConfigException, Interrupted
         rpcServer = new RpcServer(TaskManagerConfig.getServerPort(), options);
         rpcServer.registerService(new TaskManagerImpl());
         rpcServer.start();
-        log.info("Start TaskManager on {} with worker thread number {}", TaskManagerConfig.getServerPort(),
-                TaskManagerConfig.getServerWorkerThreads());
+        logger.info(String.format("Start TaskManager on %d with worker thread number %d",
+                        TaskManagerConfig.getServerPort(), TaskManagerConfig.getServerWorkerThreads()));
 
         if (blocking) {
             // make server keep running