···
CREATE TABLE IF NOT EXISTS test_wl7 as SELECT hive_query_id,
jobid,
TYPE,
task_count,
start_time,
finish_time,
max_task,
pre_task,
yarnuser,
regexp_replace(hive_query_string,
'\n|\r',
' ') hive_query_string,
update_user,
etl_tx_dt
FROM dev_test_dc.mapred_job_history_skew
WHERE etl_tx_dt=20190730 ;
···
采集的用户sql,分析后通过sqoop将hive(表的格式是textfile)导入到mysql中。因为sql中存在换行符。需要替换。注意是\n|\r.有个\r..
网友评论