diff --git a/external/mlsql-autosuggest/src/test/java/com/intigua/antlr4/autosuggest/TableStructureTest.scala b/external/mlsql-autosuggest/src/test/java/com/intigua/antlr4/autosuggest/TableStructureTest.scala
index ede1448bd..83f18c705 100644
--- a/external/mlsql-autosuggest/src/test/java/com/intigua/antlr4/autosuggest/TableStructureTest.scala
+++ b/external/mlsql-autosuggest/src/test/java/com/intigua/antlr4/autosuggest/TableStructureTest.scala
@@ -104,7 +104,7 @@ class TableStructureTest extends BaseTest with Logging {
     val root = suggester.sqlAST
     root.visitDown(0) { case (ast, level) =>
       if (log.isInfoEnabled()) {
-        log.info(s"${ast.name(suggester.tokens)} ${ast.output(suggester.tokens)}")
+        log.info("{} {}", ast.name(suggester.tokens), ast.output(suggester.tokens))
       }
     }
 
diff --git a/streamingpro-core/src/main/java/org/apache/spark/ps/cluster/PSExecutorBackend.scala b/streamingpro-core/src/main/java/org/apache/spark/ps/cluster/PSExecutorBackend.scala
index 4962a9df3..695b9d6d6 100644
--- a/streamingpro-core/src/main/java/org/apache/spark/ps/cluster/PSExecutorBackend.scala
+++ b/streamingpro-core/src/main/java/org/apache/spark/ps/cluster/PSExecutorBackend.scala
@@ -165,14 +165,14 @@ object PSExecutorBackend {
             argv = tail
           case item::value::tail if item.startsWith("--")=>
             if (log.isInfoEnabled()) {
-              log.info(s"ignore options: ${item} ${value}--")
+              log.info("ignore options: {} {}--", item, value)
             }
             argv = tail
 
           case Nil =>
           case tail =>
             if (log.isInfoEnabled()) {
-              log.info(s"Unrecognized options: ${tail.mkString(" ")}")
+              log.info("Unrecognized options: {}", tail.mkString(" "))
             }
         }
       }
diff --git a/streamingpro-it/src/test/scala/tech/mlsql/it/TestManager.scala b/streamingpro-it/src/test/scala/tech/mlsql/it/TestManager.scala
index 768f095dc..29220bf8e 100644
--- a/streamingpro-it/src/test/scala/tech/mlsql/it/TestManager.scala
+++ b/streamingpro-it/src/test/scala/tech/mlsql/it/TestManager.scala
@@ -55,8 +55,8 @@ object TestManager extends Logging {
 
   def recordError(testCase: TestCase, msg: String): Unit = {
     failedCases += Tuple2(testCase, msg)
-    logError("========================= Error Test Case =========================")
-    logError(s"Error: TestCase ${testCase.name} failed, error msg is: $msg")
+    log.error("========================= Error Test Case =========================")
+    log.error("Error: TestCase {} failed, error msg is: {}", testCase.name, msg)
   }
 
 
diff --git a/streamingpro-mlsql/src/main/java/streaming/dsl/mmlib/algs/SQLTokenAnalysis.scala b/streamingpro-mlsql/src/main/java/streaming/dsl/mmlib/algs/SQLTokenAnalysis.scala
index 7063529f5..a2492fcf1 100644
--- a/streamingpro-mlsql/src/main/java/streaming/dsl/mmlib/algs/SQLTokenAnalysis.scala
+++ b/streamingpro-mlsql/src/main/java/streaming/dsl/mmlib/algs/SQLTokenAnalysis.scala
@@ -100,7 +100,7 @@ object SQLTokenAnalysis {
       parser.getClass.getMethod("parseStr", classOf[String]).invoke(parser, content)
     } catch {
       case e: Exception =>
-        log.error(s"Parser Invoke Error: {}\n Exception: {}", content, e)
+        log.error("Parser Invoke Error: {}\n Exception: {}", content, e)
         throw e
     }
 
diff --git a/streamingpro-mlsql/src/main/java/streaming/dsl/mmlib/algs/feature/DoubleFeature.scala b/streamingpro-mlsql/src/main/java/streaming/dsl/mmlib/algs/feature/DoubleFeature.scala
index 1549f2eaa..5466ba636 100644
--- a/streamingpro-mlsql/src/main/java/streaming/dsl/mmlib/algs/feature/DoubleFeature.scala
+++ b/streamingpro-mlsql/src/main/java/streaming/dsl/mmlib/algs/feature/DoubleFeature.scala
@@ -101,7 +101,7 @@ object DoubleFeature extends BaseFeatureFunctions {
     val max = trainParams.getOrElse("max", "1").toDouble
     val scaleRange = max - min
     if (log.isInfoEnabled()) {
-      log.info(s"predict: ${originalRange.mkString(",")} ${minArray.mkString(",")} ${scaleRange} $min")
+      log.info("predict: {} {} {} {}", originalRange.mkString(","), minArray.mkString(","), scaleRange, min)
     }
     minMaxFunc(originalRange, minArray, scaleRange, min)
 
@@ -186,7 +186,7 @@ object DoubleFeature extends BaseFeatureFunctions {
         val scaleRange = max - min
 
         if (log.isInfoEnabled()) {
-          log.info(s"train: ${originalRange.mkString(",")} ${minArray.mkString(",")} ${scaleRange} $min")
+          log.info("train: {} {} {} {}", originalRange.mkString(","), minArray.mkString(","), scaleRange, min)
         }
         minMaxFunc(originalRange, minArray, scaleRange, min)