From 32a798c2e4747c955bb23ebe305f4b6c17a4b2e5 Mon Sep 17 00:00:00 2001
From: wangkuan <wangkuan@geedgenetworks.com>
Date: Fri, 24 May 2024 10:18:24 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9source=5Fport=E5=92=8Cdestina?=
 =?UTF-8?q?tion=5Fport=E7=B1=BB=E5=9E=8B=E4=B8=BANullable(Int32)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../clickhouse/tsg_olap_clickhouse_ddl_24.05.sql     | 12 ++++++------
 .../tsg_olap_clickhouse_ddl_upgrade_24.05.sql        | 12 ++++++------
 2 files changed, 12 insertions(+), 12 deletions(-)

diff --git a/tsg_olap/upgrade/TSG-24.05/clickhouse/tsg_olap_clickhouse_ddl_24.05.sql b/tsg_olap/upgrade/TSG-24.05/clickhouse/tsg_olap_clickhouse_ddl_24.05.sql
index b29b84c..6fd5fc5 100644
--- a/tsg_olap/upgrade/TSG-24.05/clickhouse/tsg_olap_clickhouse_ddl_24.05.sql
+++ b/tsg_olap/upgrade/TSG-24.05/clickhouse/tsg_olap_clickhouse_ddl_24.05.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
diff --git a/tsg_olap/upgrade/TSG-24.05/clickhouse/tsg_olap_clickhouse_ddl_upgrade_24.05.sql b/tsg_olap/upgrade/TSG-24.05/clickhouse/tsg_olap_clickhouse_ddl_upgrade_24.05.sql
index 1954c9a..90ea683 100644
--- a/tsg_olap/upgrade/TSG-24.05/clickhouse/tsg_olap_clickhouse_ddl_upgrade_24.05.sql
+++ b/tsg_olap/upgrade/TSG-24.05/clickhouse/tsg_olap_clickhouse_ddl_upgrade_24.05.sql
@@ -13,9 +13,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
@@ -34,9 +34,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
@@ -56,9 +56,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