(seatunnel) branch dev updated: [Improve][Connector-V2][WeChat] Optimize StringBuffer to StringBuilder for better performance (#10127)

[lidongdai]

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

lidongdai pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 2ecdca2ab1 [Improve][Connector-V2][WeChat] Optimize StringBuffer to 
StringBuilder for better performance (#10127)
2ecdca2ab1 is described below

commit 2ecdca2ab18d37726f92901df66828983afd7262
Author: corgy-w <73771213+corg...@users.noreply.github.com>
AuthorDate: Fri Nov 28 22:37:42 2025 +0800

    [Improve][Connector-V2][WeChat] Optimize StringBuffer to StringBuilder for 
better performance (#10127)
---
 .../wechat/sink/WeChatBotMessageSerializationSchema.java     | 12 ++++++++----
 1 file changed, 8 insertions(+), 4 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-http/connector-http-wechat/src/main/java/org/apache/seatunnel/connectors/seatunnel/wechat/sink/WeChatBotMessageSerializationSchema.java
 
b/seatunnel-connectors-v2/connector-http/connector-http-wechat/src/main/java/org/apache/seatunnel/connectors/seatunnel/wechat/sink/WeChatBotMessageSerializationSchema.java
index f10c69ca2c..0c8b6d7aa6 100644
--- 
a/seatunnel-connectors-v2/connector-http/connector-http-wechat/src/main/java/org/apache/seatunnel/connectors/seatunnel/wechat/sink/WeChatBotMessageSerializationSchema.java
+++ 
b/seatunnel-connectors-v2/connector-http/connector-http-wechat/src/main/java/org/apache/seatunnel/connectors/seatunnel/wechat/sink/WeChatBotMessageSerializationSchema.java
@@ -46,18 +46,22 @@ public class WeChatBotMessageSerializationSchema implements 
SerializationSchema
     @SneakyThrows
     @Override
     public byte[] serialize(SeaTunnelRow row) {
-        StringBuffer stringBuffer = new StringBuffer();
+        StringBuilder stringBuilder = new StringBuilder();
         int totalFields = rowType.getTotalFields();
         for (int i = 0; i < totalFields; i++) {
-            stringBuffer.append(rowType.getFieldName(i) + ": " + 
row.getField(i) + "\\n");
+            stringBuilder
+                    .append(rowType.getFieldName(i))
+                    .append(": ")
+                    .append(row.getField(i))
+                    .append("\\n");
         }
         if (totalFields > 0) {
             // remove last empty line
-            stringBuffer.delete(stringBuffer.length() - 2, 
stringBuffer.length());
+            stringBuilder.delete(stringBuilder.length() - 2, 
stringBuilder.length());
         }
 
         HashMap<Object, Object> content = new HashMap<>();
-        content.put(WeChatSinkConfig.WECHAT_SEND_MSG_CONTENT_KEY, 
stringBuffer.toString());
+        content.put(WeChatSinkConfig.WECHAT_SEND_MSG_CONTENT_KEY, 
stringBuilder.toString());
         if (!CollectionUtils.isEmpty(weChatSinkConfig.getMentionedList())) {
             content.put(
                     WeChatSinkOptions.MENTIONED_LIST.key(), 
weChatSinkConfig.getMentionedList());