From a28806311a3e1b3f731a7f9e687a06407f100724 Mon Sep 17 00:00:00 2001 From: "ziyang.lb" Date: Fri, 24 May 2024 17:53:55 +0800 Subject: [PATCH] fix bug : full ddl sqls should not assign to extra field but data field --- .../otter/canal/parse/inbound/mysql/tsdb/DatabaseTableMeta.java | 2 +- 1 file changed, 1 insertion(+), 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 b110fe16..beab52d8 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 @@ -364,7 +364,7 @@ public class DatabaseTableMeta implements TableMetaTSDB { snapshotDO.setBinlogOffest(position.getPosition()); snapshotDO.setBinlogMasterId(String.valueOf(position.getServerId())); snapshotDO.setBinlogTimestamp(position.getTimestamp()); - snapshotDO.setExtra(JSON.toJSONString(schemaDdls)); + snapshotDO.setData(JSON.toJSONString(schemaDdls)); try { metaSnapshotDAO.insert(snapshotDO); } catch (Throwable e) {