[Bugfix] Doris Sink should not throw exception when the transaction is already committed/visible

Author: zhousimin

seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/committer/DorisCommitter.java

@@ -117,7 +117,8 @@ private void commitTransaction(DorisCommitInfo committable)
             String loadResult = EntityUtils.toString(response.getEntity());
             Map<String, String> res =
                     mapper.readValue(loadResult, new TypeReference<HashMap<String, String>>() {});
-            if (!LoadStatus.SUCCESS.equals(res.get("status"))) {
+            if (!LoadStatus.SUCCESS.equals(res.get("status"))
+                    && !ResponseUtil.isCommitted(res.get("msg"))) {
                 log.error(
                         "commit transaction error url:{},TxnId:{},result:{}",
                         String.format(COMMIT_PATTERN, hostPort, committable.getDb()),

seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/util/ResponseUtil.java

@@ -31,6 +31,6 @@ public class ResponseUtil {
                             + "is already \\b(COMMITTED|committed|VISIBLE|visible)\\b, not pre-committed.");
 
     public static boolean isCommitted(String msg) {
-        return COMMITTED_PATTERN.matcher(msg).matches();
+        return COMMITTED_PATTERN.matcher(msg).find();
     }
 }