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