22.01 update

This commit is contained in:
zhanghongqing
2021-12-27 16:40:42 +08:00
parent 1bc23b7a60
commit 4b48db9376
2 changed files with 76 additions and 1 deletions

View File

@@ -43,4 +43,9 @@ spark
gohangout
1.更新config下所有任务配置max.partition.fetch.bytes: '31457280'
执行完成后重启所有gohangout
执行完成后重启所有gohangout
更新验证
1.添加SQL统一验证方式为执行完SQL后查询添加的表或字段是否已经存在。
2.

View File

@@ -0,0 +1,70 @@
ALTER TABLE tsg_galaxy_v3.session_record_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.interim_session_record_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.transaction_record_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.security_event_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.proxy_event_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.sys_packet_capture_event_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.radius_record_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.gtpc_record_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.voip_record_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.session_record ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.interim_session_record ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.transaction_record ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.security_event ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.proxy_event ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.sys_packet_capture_event ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.radius_record ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.gtpc_record ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.voip_record ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.session_record ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.interim_session_record ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.transaction_record ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.security_event ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.proxy_event ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.sys_packet_capture_event ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.radius_record ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.gtpc_record ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.voip_record ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS common_stream_behavior String after common_device_group;
ALTER TABLE tsg_galaxy_v3.session_record ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS stratum_mining_program String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.session_record ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS stratum_mining_pools String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.session_record ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS stratum_cryptocurrency String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.security_event ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS stratum_mining_program String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.security_event ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS stratum_mining_pools String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.security_event ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS stratum_cryptocurrency String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.interim_session_record ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS stratum_mining_program String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.interim_session_record ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS stratum_mining_pools String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.interim_session_record ON CLUSTER ck_query ADD COLUMN IF NOT EXISTS stratum_cryptocurrency String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.session_record ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS stratum_mining_program String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.session_record ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS stratum_mining_pools String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.session_record ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS stratum_cryptocurrency String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.security_event ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS stratum_mining_program String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.security_event ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS stratum_mining_pools String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.security_event ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS stratum_cryptocurrency String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.interim_session_record ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS stratum_mining_program String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.interim_session_record ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS stratum_mining_pools String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.interim_session_record ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS stratum_cryptocurrency String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.session_record_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS stratum_mining_program String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.session_record_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS stratum_mining_pools String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.session_record_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS stratum_cryptocurrency String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.security_event_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS stratum_mining_program String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.security_event_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS stratum_mining_pools String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.security_event_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS stratum_cryptocurrency String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.interim_session_record_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS stratum_mining_program String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.interim_session_record_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS stratum_mining_pools String after ssh_hassh;
ALTER TABLE tsg_galaxy_v3.interim_session_record_local ON CLUSTER ck_cluster ADD COLUMN IF NOT EXISTS stratum_cryptocurrency String after ssh_hassh;