fix gc log bug

WeDataSphere · Dec 6, 2023 · 439c85f · 439c85f
1 parent a9359e2
commit 439c85f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...e/src/main/scala/org/apache/linkis/engineconnplugin/flink/util/FlinkValueFormatUtil.scala b/...e/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
     }