State | Dag Id | Task Id | Execution Date | Operator | Start Date | End Date | Duration | Job Id | Hostname | Unixname | Priority Weight | Queue | Queued Dttm | Try Number | Pool | Log Url | ||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
success | airflow_tv_ls_recall | merge_recall_mv |
|
BashOperator |
|
|
0:00:03.827670 | 770 |
|
dev | 3 | default |
|
3 | default_pool | |||
success | airflow_tv_ls_recall | run_sdm_mv |
|
BashOperator |
|
|
769 |
|
dev | 4 | default |
|
4 | default_pool | ||||
success | airflow_tv_ls_recall | upload_recall_to_hive |
|
SparkSubmitOperator |
|
|
0:01:51.378000 | 768 |
|
dev | 5 | default |
|
7 | default_pool | |||
success | airflow_tv_ls_recall | merge_recall |
|
BashOperator |
|
|
0:00:05.040680 | 767 |
|
dev | 6 | default |
|
3 | default_pool | |||
success | airflow_tv_ls_recall | run_sdm |
|
BashOperator |
|
|
1:22:14 | 766 |
|
dev | 7 | default |
|
3 | default_pool | |||
success | airflow_tv_ls_recall | get_tv_sp_traning_data_to_local_ls |
|
SparkSubmitOperator |
|
|
0:00:43.193900 | 765 |
|
dev | 8 | default |
|
3 | default_pool | |||
success | airflow_tv_ls_recall | get_tv_sp_traning_data_to_local |
|
SparkSubmitOperator |
|
|
0:01:09.970100 | 764 |
|
dev | 8 | default |
|
3 | default_pool | |||
success | airflow_tv_ls_recall | get_mv_training_data_to_local_ls |
|
SparkSubmitOperator |
|
|
0:00:14.879300 | 720 |
|
dev | 6 | default |
|
3 | default_pool | |||
success | airflow_tv_ls_recall | get_mv_training_data_to_local |
|
SparkSubmitOperator |
|
|
0:00:42.029700 | 713 |
|
dev | 6 | default |
|
2 | default_pool | |||
success | airflow_tv_ls_recall | update_media_mv |
|
BashOperator |
|
|
0:01:43.308000 | 712 |
|
dev | 7 | default |
|
6 | default_pool | |||
success | airflow_tv_ls_recall | update_media_type |
|
BashOperator |
|
|
0:01:01.524100 | 614 |
|
dev | 11 | default |
|
2 | default_pool | |||
success | airflow_tv_ls_recall | upload_recall_to_hive |
|
SparkSubmitOperator |
|
|
0:00:09.859360 | 538 |
|
root | 8 | default |
|
3 | default_pool | |||
success | airflow_tv_ls_recall | merge_recall |
|
BashOperator |
|
|
0:00:00.551716 | 536 |
|
root | 9 | default |
|
2 | default_pool | |||
success | airflow_tv_ls_recall | run_sdm |
|
BashOperator |
|
|
1:52:53.830000 | 535 |
|
root | 10 | default |
|
6 | default_pool | |||
success | airflow_tv_ls_recall | update_media_type |
|
BashOperator |
|
|
0:00:58.304800 | 534 |
|
root | 11 | default |
|
4 | default_pool | |||
success | airflow_tv_ls_recall | get_tv_sp_traning_data_to_local_ls |
|
SparkSubmitOperator |
|
|
0:00:39.044000 | 533 |
|
root | 12 | default |
|
4 | default_pool | |||
success | airflow_tv_ls_recall | get_tv_sp_traning_data_to_local |
|
SparkSubmitOperator |
|
|
0:01:22.982700 | 532 |
|
root | 12 | default |
|
4 | default_pool | |||
success | airflow_tv_ls_recall | merge_recall |
|
BashOperator |
|
|
0:00:23.261700 | 262 |
|
root | 1 | default |
|
2 | default_pool | |||
success | airflow_tv_ls_recall | sim_paid |
|
BashOperator |
|
|
0:12:53.094000 | 261 |
|
root | 2 | default |
|
2 | default_pool | |||
success | airflow_tv_ls_recall | run_sdm |
|
BashOperator |
|
|
0:59:15.700000 | 260 |
|
root | 3 | default |
|
2 | default_pool | |||
success | airflow_tv_ls_recall | update_media_type |
|
BashOperator |
|
|
0:01:21.287800 | 259 |
|
root | 4 | default |
|
2 | default_pool | |||
success | airflow_tv_ls_recall | get_tv_sp_traning_data_to_local |
|
SparkSubmitOperator |
|
|
0:00:15.688900 | 258 |
|
root | 5 | default |
|
2 | default_pool | |||
success | airflow_tv_ls_recall | get_tv_sp_traning_data_to_local_ls |
|
SparkSubmitOperator |
|
|
0:00:15.543200 | 257 |
|
root | 5 | default |
|
2 | default_pool | |||
success | airflow_tv_ls_recall | kill_large_processes |
|
BashOperator |
|
|
0:00:00.108369 | 256 |
|
root | 7 | default |
|
2 | default_pool | |||
success | airflow_tv_ls_recall | merge_recall |
|
BashOperator |
|
|
0:00:22.828500 | 206 |
|
root | 1 | default |
|
2 | default_pool | |||
success | airflow_tv_ls_recall | sim_paid |
|
BashOperator |
|
|
0:13:41.889000 | 205 |
|
root | 2 | default |
|
2 | default_pool | |||
success | airflow_tv_ls_recall | run_sdm |
|
BashOperator |
|
|
0:52:05.260000 | 204 |
|
root | 3 | default |
|
2 | default_pool | |||
success | airflow_tv_ls_recall | update_media_type |
|
BashOperator |
|
|
0:02:13.573000 | 203 |
|
root | 4 | default |
|
2 | default_pool | |||
success | airflow_tv_ls_recall | get_tv_sp_traning_data_to_local_ls |
|
SparkSubmitOperator |
|
|
0:00:14.559600 | 202 |
|
root | 5 | default |
|
2 | default_pool | |||
success | airflow_tv_ls_recall | get_tv_sp_traning_data_to_local |
|
SparkSubmitOperator |
|
|
0:00:21.509300 | 201 |
|
root | 5 | default |
|
2 | default_pool | |||
success | airflow_tv_ls_recall | kill_large_processes |
|
BashOperator |
|
|
0:00:00.106319 | 200 |
|
root | 7 | default |
|
2 | default_pool | |||
success | airflow_tv_ls_recall | merge_recall |
|
BashOperator |
|
|
0:00:22.689800 | 139 |
|
root | 1 | default |
|
2 | default_pool | |||
success | airflow_tv_ls_recall | sim_paid |
|
BashOperator |
|
|
0:11:51.374000 | 138 |
|
root | 2 | default |
|
2 | default_pool | |||
success | airflow_tv_ls_recall | run_sdm |
|
BashOperator |
|
|
0:50:38.350000 | 137 |
|
root | 3 | default |
|
6 | default_pool | |||
success | airflow_tv_ls_recall | update_media_type |
|
BashOperator |
|
|
0:01:39.271900 | 113 |
|
root | 12 | default |
|
5 | default_pool | |||
success | airflow_tv_ls_recall | get_tv_sp_traning_data_to_local |
|
SparkSubmitOperator |
|
|
0:00:17.991900 | 111 |
|
root | 13 | default |
|
3 | default_pool | |||
success | airflow_tv_ls_recall | get_tv_sp_traning_data_to_local_ls |
|
SparkSubmitOperator |
|
|
0:00:15.907900 | 75 |
|
root | 13 | default |
|
2 | default_pool | |||
success | airflow_tv_ls_recall | kill_large_processes |
|
BashOperator |
|
|
0:00:00.123253 | 73 |
|
root | 15 | default |
|
2 | default_pool | |||
success | airflow_tv_ls_recall | aid_up |
|
BashOperator |
|
|
|
dev | 9 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | filter_aid |
|
BashOperator |
|
|
|
dev | 8 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | get_mv_training_data_to_local |
|
SparkSubmitOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | get_tv_sp_traning_data_to_local |
|
SparkSubmitOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | get_tv_sp_traning_data_to_local_ls |
|
SparkSubmitOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | merge_recall |
|
BashOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | merge_recall_1 |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | merge_recall_1 |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | merge_recall_1 |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | merge_recall_mv |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | merge_recall_mv |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | run_sdm |
|
BashOperator |
|
|
|
dev | 7 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | run_sdm |
|
BashOperator |
|
|
|
dev | 5 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | run_sdm_01 |
|
BashOperator |
|
|
|
dev | 4 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | run_sdm_38 |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | run_sdm_mv |
|
BashOperator |
|
|
|
dev | 5 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | run_sdm_mv |
|
BashOperator |
|
|
|
dev | 4 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | update_media_mv |
|
SparkSubmitOperator |
|
|
|
dev | 7 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | upload_filter_recall_to_hive_mv |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | upload_filter_recall_to_hive_mv |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | upload_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 5 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | upload_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | upload_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | upload_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | upload_recall_to_hive_mv |
|
SparkSubmitOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | upload_recall_to_hive_mv |
|
SparkSubmitOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool |