diff --git a/escheduler-server/src/main/java/cn/escheduler/server/rpc/LoggerServer.java b/escheduler-server/src/main/java/cn/escheduler/server/rpc/LoggerServer.java
index 4e12ced00069ed0851d9c6ae9bf1e720a9e7fd39..dc56119c8775867910355ead31fd45c494cdc575 100644
--- a/escheduler-server/src/main/java/cn/escheduler/server/rpc/LoggerServer.java
+++ b/escheduler-server/src/main/java/cn/escheduler/server/rpc/LoggerServer.java
@@ -196,7 +196,7 @@ public class LoggerServer {
                     errorLineFlag = filterLine(path,line);
                 }
 
-                if (!errorLineFlag || !line.startsWith("TaskLogger")){
+                if (!errorLineFlag || !line.contains("TaskLogger")){
                     sb.append(line + "\r\n");
                 }
             }
@@ -224,7 +224,7 @@ public class LoggerServer {
      * @return
      */
     private static boolean filterLine(String path,String line){
-        String removeSuffix = path.split("\\.")[0];
+        String removeSuffix = path.substring(0, path.length() - 4);
         String[] strArrs = removeSuffix.split("/");
         String taskAppId = String.format("%s_%s_%s",
                 strArrs[strArrs.length - 3],