Doris重建ROUTINE任务过程

查看任务 SHOW  ROUTINE LOAD 

查看建任务脚本 SHOW CREATE ROUTINE LOAD FOR kjob_rt_ods_log_aa_action_v1

删除任务 STOP ROUTINE LOAD FOR flydata_game_dwh_v1.kjob_rt_ods_log_aa_action;

重建

CREATE ROUTINE LOAD kjob_rt_ods_log_aa_action_v1 ON rt_ods_log_aa_action WITH APPEND COLUMNS(uuid,event,event_time = from_second(((`action_time` / 1000))),action_time,device_id,user_id,app_id,platform,package,session_id,app_version,device_type,network_type,os,source,sdk_version,ad_channel,campaign_group_id,campaign_group_name,timezone
) PROPERTIES ("desired_concurrent_number" = "3","max_error_number" = "0","max_filter_ratio" = "1.0","max_batch_interval" = "10","max_batch_rows" = "20000000","max_batch_size" = "1073741824","format" = "json","jsonpaths" = "[\"$.uuid\", \"$.event\", \"$.timestamp\", \"$.properties.deviceID\", \"$.userId\", \"$.appId\", \"$.platform\", \"$.package\", \"$.sessionId\", \"$.properties.appVersion\", \"$.properties.deviceType\", \"$.properties.networkType\", \"$.properties.os\", \"$.source\", \"$.sdkVersion\", \"$.properties.adChannel\", \"$.properties.campaignGroupId\", \"$.properties.campaignGroupName\", \"$.timezone\"]","strip_outer_array" = "false","num_as_string" = "false","fuzzy_parse" = "false","strict_mode" = "false","timezone" = "UTC","exec_mem_limit" = "2147483648"
)
FROMKAFKA ("kafka_broker_list" = "172.31.2.223:9092,172.31.8.68:9092,172.31.21.29:9092","kafka_topic" = "ods_10003_appAction","property.kafka_default_offsets" = "OFFSET_BEGINNING","property.group.id" = "kafka_v2_job");