From 07768069a330d7521af2bcfb8b2645be37560be4 Mon Sep 17 00:00:00 2001
From: wangkuan <wangkuan@geedgenetworks.com>
Date: Mon, 3 Jun 2024 10:01:57 +0800
Subject: [PATCH] =?UTF-8?q?05=E7=89=88=E6=9C=AC=E4=BF=AE=E6=94=B9tsg=5Fgal?=
 =?UTF-8?q?axy=5Fv3.datapath=5Ftelemetry=5Frecord=E8=A1=A8=E4=B8=AD?=
 =?UTF-8?q?=E4=B8=A4=E4=B8=AA=E7=AB=AF=E5=8F=A3=E7=9A=84=E5=AD=97=E6=AE=B5?=
 =?UTF-8?q?=E7=B1=BB=E5=9E=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../最新全量建表语句/tsg_olap_clickhouse_ddl.sql     |  8 ++++----
 .../旧部署模式建表语句/tsg_olap_clickhouse_ddl.sql   | 12 ++++++------
 2 files changed, 10 insertions(+), 10 deletions(-)

diff --git a/tsg_olap/installation/clickhouse/最新全量建表语句/tsg_olap_clickhouse_ddl.sql b/tsg_olap/installation/clickhouse/最新全量建表语句/tsg_olap_clickhouse_ddl.sql
index bfa7279..8d08920 100644
--- a/tsg_olap/installation/clickhouse/最新全量建表语句/tsg_olap_clickhouse_ddl.sql
+++ b/tsg_olap/installation/clickhouse/最新全量建表语句/tsg_olap_clickhouse_ddl.sql
@@ -3208,9 +3208,9 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.datapath_telemetry_record_local on clus
     device_group String,
     traffic_link_id Int32,
     source_ip String,
-    source_port Int32,
+    source_port Nullable(Int32),
     destination_ip String,
-    destination_port Int32,
+    destination_port Nullable(Int32),
     packet String,
     packet_length Int32,
     measurements String
@@ -3229,9 +3229,9 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.datapath_telemetry_record on cluster ck
     device_group String,
     traffic_link_id Int32,
     source_ip String,
-    source_port Int32,
+    source_port Nullable(Int32),
     destination_ip String,
-    destination_port Int32,
+    destination_port Nullable(Int32),
     packet String,
     packet_length Int32,
     measurements String
diff --git a/tsg_olap/installation/clickhouse/最新全量建表语句/旧部署模式建表语句/tsg_olap_clickhouse_ddl.sql b/tsg_olap/installation/clickhouse/最新全量建表语句/旧部署模式建表语句/tsg_olap_clickhouse_ddl.sql
index b29b84c..6fd5fc5 100644
--- a/tsg_olap/installation/clickhouse/最新全量建表语句/旧部署模式建表语句/tsg_olap_clickhouse_ddl.sql
+++ b/tsg_olap/installation/clickhouse/最新全量建表语句/旧部署模式建表语句/tsg_olap_clickhouse_ddl.sql
@@ -4282,9 +4282,9 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.datapath_telemetry_record_local on clus
     device_group String,
     traffic_link_id Int32,
     source_ip String,
-    source_port Int32,
+    source_port Nullable(Int32),
     destination_ip String,
-    destination_port Int32,
+    destination_port Nullable(Int32),
     packet String,
     packet_length Int32,
     measurements String
@@ -4303,9 +4303,9 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.datapath_telemetry_record on cluster ck
     device_group String,
     traffic_link_id Int32,
     source_ip String,
-    source_port Int32,
+    source_port Nullable(Int32),
     destination_ip String,
-    destination_port Int32,
+    destination_port Nullable(Int32),
     packet String,
     packet_length Int32,
     measurements String
@@ -4325,9 +4325,9 @@ ENGINE = Distributed('ck_cluster',
     device_group String,
     traffic_link_id Int32,
     source_ip String,
-    source_port Int32,
+    source_port Nullable(Int32),
     destination_ip String,
-    destination_port Int32,
+    destination_port Nullable(Int32),
     packet String,
     packet_length Int32,
     measurements String