DataHubScheduler - Details for Stage 37311 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 1 ms
Locality Level Summary: Process local: 1
Input Size / Records: 5.0 MiB / 2
Shuffle Write Size / Records: 59.0 B / 1
Associated Job Ids: 26870

digraph G { subgraph clusterstage_37311 { label="Stage 37311"; 161073 [labelType="html" label="JDBCRDD [161073] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; subgraph cluster388181 { label="Scan JDBCRelation((SELECT * FROM dbo.fact_trans_chain_po_detail WHERE bigid BETWEEN 1 AND 10000) AS page) [numPartitions=1] "; 161074 [labelType="html" label="MapPartitionsRDD [161074] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } subgraph cluster388182 { label="mapPartitionsInternal"; 161075 [labelType="html" label="MapPartitionsRDD [161075] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } subgraph cluster388183 { label="mapPartitionsInternal"; 161076 [labelType="html" label="Scan JDBCRelation((SELECT * FROM dbo.fact_trans_chain_po_detail WHERE bigid BETWEEN 1 AND 10000) AS page) [numPartitions=1] [po_item_product_code#15129212,po_item_product_name#15129213,transaction_id#15129214,buyer_gln#15129215,seller_gln#15129216,pod_division#15129217,pod_delivery_date#15129218,pod_product_item_id#15129219,pod_product_entity#15129220,po_number#15129221,product_item_id#15129222,product_entity#15129223,brand_context_id#15129224,po_division#15129225,po_delivery_date#15129226,row_id#15129227L,parent_row_id#15129228,chain_seq#15129229,tier#15129230,production_input_type#15129231,trans_create_ts#15129232,trans_update_ts#15129233,outbound_create_ts#15129234,outbound_supplier_code#15129235,... 111 more fields] PushedFilters: [], ReadSchema: struct<po_item_product_code:string,po_item_product_name:string,transaction_id:string,buyer_gln:st...\n [161076] [Cached] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } subgraph cluster388216 { label="InMemoryTableScan"; 161091 [labelType="html" label="MapPartitionsRDD [161091] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; 161092 [labelType="html" label="MapPartitionsRDD [161092] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; 161093 [labelType="html" label="MapPartitionsRDD [161093] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } subgraph cluster388212 { label="WholeStageCodegen (1)"; 161094 [labelType="html" label="MapPartitionsRDD [161094] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } subgraph cluster388211 { label="Exchange"; 161095 [labelType="html" label="MapPartitionsRDD [161095] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } } 161073->161074; 161074->161075; 161075->161076; 161076->161091; 161091->161092; 161092->161093; 161093->161094; 161094->161095; }

161076

Event Timeline

Enable zooming