[incubator-streampark] branch dev updated: fix:inserting failure when the values contain 'value' (#2932)

[zhouli]

This is an automated email from the ASF dual-hosted git repository.

zhouli pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/dev by this push:
     new e8cb2bc43 fix:inserting failure when the values contain 'value' (#2932)
e8cb2bc43 is described below

commit e8cb2bc43e68b3e1ecd05f816f10db9891ee6124
Author: caogaoshuai <2937287...@qq.com>
AuthorDate: Fri Aug 11 15:53:22 2023 +0800

    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: 劲松 <gaoshuai....@alibaba-inc.com>
---
 .../org/apache/streampark/flink/connector/failover/SinkRequest.scala    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/streampark-flink/streampark-flink-connector/streampark-flink-connector-base/src/main/scala/org/apache/streampark/flink/connector/failover/SinkRequest.scala
 
b/streampark-flink/streampark-flink-connector/streampark-flink-connector-base/src/main/scala/org/apache/streampark/flink/connector/failover/SinkRequest.scala
index 18140f088..9593d6c7c 100644
--- 
a/streampark-flink/streampark-flink-connector/streampark-flink-connector-base/src/main/scala/org/apache/streampark/flink/connector/failover/SinkRequest.scala
+++ 
b/streampark-flink/streampark-flink-connector/streampark-flink-connector-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]]()