Browse Source

添加历史数据导入

wdl 2 years ago
parent
commit
e34c86e09a
1 changed files with 1 additions and 1 deletions
  1. 1 1
      energy/dayTask/bus_mysql_to_hdfs.sh

+ 1 - 1
energy/dayTask/bus_mysql_to_hdfs.sh

@@ -72,7 +72,7 @@ ods_feedback(){
 }
 
 ods_feedback_tmp(){
-  mysql_to_hdfs_lzo "$url" "$username" "$password" /warehouse/saga_dw/ods/tmp/  \
+  mysql_to_hdfs_lzo_no_partition "$url" "$username" "$password" /warehouse/saga_dw/ods/tmp/  \
   "id, project_id, object_id, source_type, user_id, user_phone, user_name, value_type, item_id, value, create_time, next_open_time, model, duration_type, custom_plan, curr_temp, nick_name, result, exe_result, fb_temp, remark" \
   "select id, project_id, object_id, source_type, user_id, user_phone, user_name, value_type, item_id, value, create_time, next_open_time, model, duration_type, custom_plan, curr_temp, nick_name, result, exe_result, fb_temp, remark from feedback where 1 = 1 " \
   ods_bus_feedback_tmp