diff --git a/TSG-21.03/Clickhouse/add_column.txt b/TSG-21.03/Clickhouse/add_column.txt
index 146e6bf..c91fd09 100644
--- a/TSG-21.03/Clickhouse/add_column.txt
+++ b/TSG-21.03/Clickhouse/add_column.txt
@@ -88,17 +88,17 @@ ALTER TABLE connection_record_log ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS
 ALTER TABLE security_event_log_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS sip_bye String after sip_duration;
 ALTER TABLE security_event_log ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS sip_bye String after sip_duration;
 
-ALTER TABLE connection_record_log_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS rtp_payload_type_c2s Int64 after sip_bye;
-ALTER TABLE connection_record_log ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS rtp_payload_type_c2s Int64 after sip_bye;
+ALTER TABLE connection_record_log_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS rtp_payload_type_c2s Nullable(Int64) after sip_bye;
+ALTER TABLE connection_record_log ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS rtp_payload_type_c2s Nullable(Int64) after sip_bye;
 
-ALTER TABLE security_event_log_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS rtp_payload_type_c2s Int64 after sip_bye;
-ALTER TABLE security_event_log ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS rtp_payload_type_c2s Int64 after sip_bye;
+ALTER TABLE security_event_log_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS rtp_payload_type_c2s Nullable(Int64) after sip_bye;
+ALTER TABLE security_event_log ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS rtp_payload_type_c2s Nullable(Int64) after sip_bye;
 
-ALTER TABLE connection_record_log_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS rtp_payload_type_s2c Int64 after rtp_payload_type_c2s;
-ALTER TABLE connection_record_log ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS rtp_payload_type_s2c Int64 after rtp_payload_type_c2s;
+ALTER TABLE connection_record_log_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS rtp_payload_type_s2c Nullable(Int64) after rtp_payload_type_c2s;
+ALTER TABLE connection_record_log ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS rtp_payload_type_s2c Nullable(Int64) after rtp_payload_type_c2s;
 
-ALTER TABLE security_event_log_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS rtp_payload_type_s2c Int64 after rtp_payload_type_c2s;
-ALTER TABLE security_event_log ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS rtp_payload_type_s2c Int64 after rtp_payload_type_c2s;
+ALTER TABLE security_event_log_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS rtp_payload_type_s2c Nullable(Int64) after rtp_payload_type_c2s;
+ALTER TABLE security_event_log ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS rtp_payload_type_s2c Nullable(Int64) after rtp_payload_type_c2s;
 
 ALTER TABLE connection_record_log_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS rtp_pcap_dir_c2s String after rtp_payload_type_s2c;
 ALTER TABLE connection_record_log ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS rtp_pcap_dir_c2s String after rtp_payload_type_s2c;
@@ -204,17 +204,17 @@ ALTER TABLE connection_record_log ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS s
 ALTER TABLE security_event_log_local ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS sip_bye String after sip_duration;
 ALTER TABLE security_event_log ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS sip_bye String after sip_duration;
 
-ALTER TABLE connection_record_log_local ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS rtp_payload_type_c2s Int64 after sip_bye;
-ALTER TABLE connection_record_log ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS rtp_payload_type_c2s Int64 after sip_bye;
+ALTER TABLE connection_record_log_local ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS rtp_payload_type_c2s Nullable(Int64) after sip_bye;
+ALTER TABLE connection_record_log ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS rtp_payload_type_c2s Nullable(Int64) after sip_bye;
 
-ALTER TABLE security_event_log_local ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS rtp_payload_type_c2s Int64 after sip_bye;
-ALTER TABLE security_event_log ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS rtp_payload_type_c2s Int64 after sip_bye;
+ALTER TABLE security_event_log_local ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS rtp_payload_type_c2s Nullable(Int64) after sip_bye;
+ALTER TABLE security_event_log ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS rtp_payload_type_c2s Nullable(Int64) after sip_bye;
 
-ALTER TABLE connection_record_log_local ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS rtp_payload_type_s2c Int64 after rtp_payload_type_c2s;
-ALTER TABLE connection_record_log ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS rtp_payload_type_s2c Int64 after rtp_payload_type_c2s;
+ALTER TABLE connection_record_log_local ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS rtp_payload_type_s2c Nullable(Int64) after rtp_payload_type_c2s;
+ALTER TABLE connection_record_log ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS rtp_payload_type_s2c Nullable(Int64) after rtp_payload_type_c2s;
 
-ALTER TABLE security_event_log_local ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS rtp_payload_type_s2c Int64 after rtp_payload_type_c2s;
-ALTER TABLE security_event_log ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS rtp_payload_type_s2c Int64 after rtp_payload_type_c2s;
+ALTER TABLE security_event_log_local ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS rtp_payload_type_s2c Nullable(Int64) after rtp_payload_type_c2s;
+ALTER TABLE security_event_log ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS rtp_payload_type_s2c Nullable(Int64) after rtp_payload_type_c2s;
 
 ALTER TABLE connection_record_log_local ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS rtp_pcap_dir_c2s String after rtp_payload_type_s2c;
 ALTER TABLE connection_record_log ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS rtp_pcap_dir_c2s String after rtp_payload_type_s2c;