From 235cc46bf8be8881e141247bacda0a5c5675a821 Mon Sep 17 00:00:00 2001 From: lingniu Date: Wed, 1 Jul 2026 00:08:49 +0800 Subject: [PATCH] fix: use varchar for raw parsed json --- .../lingniu/ingest/tdenginehistory/TdengineHistorySchema.java | 2 +- .../ingest/tdenginehistory/TdengineHistorySchemaTest.java | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) 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)")