From 9bd4357f37b80a593bb92aba310fa971a49e1a5a Mon Sep 17 00:00:00 2001
From: hygugb <gu_haiyun@163.com>
Date: Fri, 16 May 2025 15:00:19 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20tsdb=E5=AD=98=E5=82=A8=E5=85=83=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E6=97=B6=E6=94=AF=E6=8C=81=E5=A4=A7=E5=AF=B9=E8=B1=A1?=
 =?UTF-8?q?=EF=BC=88=E5=A4=A7=E4=BA=8E64M=EF=BC=89=20(#5393)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../canal/parse/inbound/mysql/tsdb/DatabaseTableMeta.java      | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/DatabaseTableMeta.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/DatabaseTableMeta.java
index fc414a99..05488b19 100644
--- a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/DatabaseTableMeta.java
+++ b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/DatabaseTableMeta.java
@@ -24,6 +24,7 @@ import org.slf4j.MDC;
 
 import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONObject;
+import com.alibaba.fastjson2.JSONWriter;
 import com.alibaba.otter.canal.filter.CanalEventFilter;
 import com.alibaba.otter.canal.parse.driver.mysql.packets.server.FieldPacket;
 import com.alibaba.otter.canal.parse.driver.mysql.packets.server.ResultSetPacket;
@@ -369,7 +370,7 @@ public class DatabaseTableMeta implements TableMetaTSDB {
             snapshotDO.setBinlogOffest(position.getPosition());
             snapshotDO.setBinlogMasterId(String.valueOf(position.getServerId()));
             snapshotDO.setBinlogTimestamp(position.getTimestamp());
-            snapshotDO.setData(JSON.toJSONString(schemaDdls));
+            snapshotDO.setData(JSON.toJSONString(schemaDdls,JSONWriter.Feature.LargeObject));
             try {
                 metaSnapshotDAO.insert(snapshotDO);
             } catch (Throwable e) {