Merge branch 'dev-1.1.15-webank-streamis-fix-gc-log-bug' into dev-1.1…

….16-webank
WeDataSphere · Oct 19, 2023 · bbfe9cb · bbfe9cb
2 parents f19fe29 + a75b7ce
commit bbfe9cb
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...k/src/main/scala/org/apache/linkis/engineconnplugin/flink/util/FlinkValueFormatUtil.scala b/...k/src/main/scala/org/apache/linkis/engineconnplugin/flink/util/FlinkValueFormatUtil.scala
@@ -63,12 +63,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
     }