2023-04-13 处理数据倾斜

INSERT OVERWRITE TABLE fin_dw.dwd_cdplabel_jt_market_strategy_info_pda PARTITION (pday= '${yesterday_p}')

SELECT  id,

        plan_id,

        plan_name,

        strategy_id,

        strategy_name,

        comp_person_num,

        task_status,

        person_num,

        person_name,

        trigger_type,

        no_send_type,

        user_no,

        totals,

        trigger_time,

        talk_length,

        trigger_status,

        task_id,

        bag_class,

        template_code,

        template_content,

        create_time,

        create_date

FROM  credit_data.temp_fin_jt_dwb_market_strategy_info_d_type

DISTRIBUTE BY PMOD(HASH(10000*rand()), 1500) ;

参考：https://zhuanlan.zhihu.com/p/252776975