diff --git a/linkis-engineconn-plugins/flink/flink-core/src/main/scala/org/apache/linkis/engineconnplugin/flink/util/FlinkValueFormatUtil.scala b/linkis-engineconn-plugins/flink/flink-core/src/main/scala/org/apache/linkis/engineconnplugin/flink/util/FlinkValueFormatUtil.scala
index e396797fe8..cf84e2aed2 100644
--- a/linkis-engineconn-plugins/flink/flink-core/src/main/scala/org/apache/linkis/engineconnplugin/flink/util/FlinkValueFormatUtil.scala
+++ b/linkis-engineconn-plugins/flink/flink-core/src/main/scala/org/apache/linkis/engineconnplugin/flink/util/FlinkValueFormatUtil.scala
@@ -57,12 +57,12 @@ object FlinkValueFormatUtil {
     var replaceStr1 = ""
     var replaceStr2 = ""
     if (xloggcValueStr1.nonEmpty && xloggcValueStr2.nonEmpty) {
-      escapedXloggcValue = xloggcValueStr2.replace("<", "\\<").replace(">", "\\>")
+      escapedXloggcValue = xloggcValueStr2.replace("\\<", "<").replace("\\>", ">")
       replaceStr1 = defaultJavaOpts.replace(xloggcValueStr1, escapedXloggcValue)
       replaceStr2 = envJavaOpts.replace(xloggcValueStr2, "")
     }
     if (xloggcValueStr1.nonEmpty && xloggcValueStr2.isEmpty) {
-      escapedXloggcValue = xloggcValueStr1.replace("<", "\\<").replace(">", "\\>")
+      escapedXloggcValue = xloggcValueStr1.replace("\\<", "<").replace("\\>", ">")
       replaceStr1 = defaultJavaOpts.replace(xloggcValueStr1, escapedXloggcValue)
       replaceStr2 = envJavaOpts
     }