Azkaban-Status统计

azkaban-statu.sql

select  ifnull( status , 'TOTAL')  status, count(  flow_id ) exec_num
from ( 
select  exec_id, project_id, flow_id

, case
        when status = 50 then 'success'
        when status = 60 then 'killed'
        when status = 70 then 'failed'

else status end status

, submit_user

, from_unixtime( end_time /1000, '%Y-%m-%d')   as start_DT

, from_unixtime( start_time /1000, '%Y-%m-%d %H') as start_DH

-- , from_unixtime( end_time /1000, '%Y-%m-%d %H')   as end_DH

, b.host as executor_host


from execution_flows a

join executors b on a.executor_id = b.id

where  a.project_id not in (27)
    -- 27 : personalization
    -- 统计数据仓库小组的任务
and submit_user in ('admin', 'yangjinyong', 'liumeng')
and from_unixtime( start_time /1000, '%Y-%m-%d') between '2019-04-01' and '2019-06-30'
and substr(from_unixtime( end_time /1000, '%H'),1,1) ='0'

order by start_DT desc

) mid
group by status
with rollup