diff --git a/modules/sinks/tdengine-history-store/src/main/java/com/lingniu/ingest/tdenginehistory/TdengineHistorySchema.java b/modules/sinks/tdengine-history-store/src/main/java/com/lingniu/ingest/tdenginehistory/TdengineHistorySchema.java
index a8eca827..f9ee1319 100644
--- a/modules/sinks/tdengine-history-store/src/main/java/com/lingniu/ingest/tdenginehistory/TdengineHistorySchema.java
+++ b/modules/sinks/tdengine-history-store/src/main/java/com/lingniu/ingest/tdenginehistory/TdengineHistorySchema.java
@@ -65,7 +65,7 @@ public final class TdengineHistorySchema {
                   parse_error NCHAR(512),
                   peer NCHAR(128),
                   metadata_json NCHAR(4096),
-                  parsed_json NCHAR(16374)
+                  parsed_json VARCHAR(16374)
                 ) TAGS (
                   protocol NCHAR(16),
                   vehicle_key NCHAR(128),
diff --git a/modules/sinks/tdengine-history-store/src/test/java/com/lingniu/ingest/tdenginehistory/TdengineHistorySchemaTest.java b/modules/sinks/tdengine-history-store/src/test/java/com/lingniu/ingest/tdenginehistory/TdengineHistorySchemaTest.java
index f97ebaad..e1c44f2f 100644
--- a/modules/sinks/tdengine-history-store/src/test/java/com/lingniu/ingest/tdenginehistory/TdengineHistorySchemaTest.java
+++ b/modules/sinks/tdengine-history-store/src/test/java/com/lingniu/ingest/tdenginehistory/TdengineHistorySchemaTest.java
@@ -20,6 +20,7 @@ class TdengineHistorySchemaTest {
                 .contains("frame_id NCHAR(64)")
                 .contains("raw_uri NCHAR(512)")
                 .contains("metadata_json NCHAR(4096)")
+                .contains("parsed_json VARCHAR(16374)")
                 .contains("TAGS (")
                 .contains("protocol NCHAR(16)")
                 .contains("vehicle_key NCHAR(128)")