fix:inserting failure when the values contain 'value' (#2932)

* fix:inserting failure when the values contain 'value' * refactor: another fix solution * refactor: amazing solution --------- Co-authored-by: 劲松 <[email protected]>
apache · Aug 11, 2023 · e8cb2bc · e8cb2bc
1 parent 73d153c
commit e8cb2bc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ctor-base/src/main/scala/org/apache/streampark/flink/connector/failover/SinkRequest.scala b/...ctor-base/src/main/scala/org/apache/streampark/flink/connector/failover/SinkRequest.scala
@@ -33,7 +33,7 @@ case class SinkRequest(records: util.List[String], var attemptCounter: Int = 0)
     Pattern.compile("(insert\\s+into|update|delete)\\s+(.*?)(\\(|\\s+)", Pattern.CASE_INSENSITIVE)
 
   private[this] lazy val INSERT_REGEXP =
-    Pattern.compile("^(.*)\\s+(values|value)(.*)", Pattern.CASE_INSENSITIVE)
+    Pattern.compile("^(.*?)\\s+(values|value)(.*)", Pattern.CASE_INSENSITIVE)
 
   lazy val sqlStatement: String = {
     val prefixMap: Map[String, List[String]] = Map[String, List[String]]()