DataHubScheduler - Details for Stage 37357 (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: 26909

digraph G { subgraph clusterstage_37357 { label="Stage 37357"; 161233 [labelType="html" label="JDBCRDD [161233] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; subgraph cluster388540 { label="Scan JDBCRelation((SELECT * FROM dbo.fact_trans_chain_po_detail WHERE bigid BETWEEN 20001 AND 30000) AS page) [numPartitions=1] "; 161234 [labelType="html" label="MapPartitionsRDD [161234] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } subgraph cluster388541 { label="mapPartitionsInternal"; 161235 [labelType="html" label="MapPartitionsRDD [161235] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } subgraph cluster388542 { label="mapPartitionsInternal"; 161236 [labelType="html" label="Scan JDBCRelation((SELECT * FROM dbo.fact_trans_chain_po_detail WHERE bigid BETWEEN 20001 AND 30000) AS page) [numPartitions=1] [po_item_product_code#15147883,po_item_product_name#15147884,transaction_id#15147885,buyer_gln#15147886,seller_gln#15147887,pod_division#15147888,pod_delivery_date#15147889,pod_product_item_id#15147890,pod_product_entity#15147891,po_number#15147892,product_item_id#15147893,product_entity#15147894,brand_context_id#15147895,po_division#15147896,po_delivery_date#15147897,row_id#15147898L,parent_row_id#15147899,chain_seq#15147900,tier#15147901,production_input_type#15147902,trans_create_ts#15147903,trans_update_ts#15147904,outbound_create_ts#15147905,outbound_supplier_code#15147906,... 111 more fields] PushedFilters: [], ReadSchema: struct<po_item_product_code:string,po_item_product_name:string,transaction_id:string,buyer_gln:st...\n [161236] [Cached] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } subgraph cluster388575 { label="InMemoryTableScan"; 161253 [labelType="html" label="MapPartitionsRDD [161253] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; 161254 [labelType="html" label="MapPartitionsRDD [161254] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; 161255 [labelType="html" label="MapPartitionsRDD [161255] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } subgraph cluster388571 { label="WholeStageCodegen (1)"; 161256 [labelType="html" label="MapPartitionsRDD [161256] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } subgraph cluster388570 { label="Exchange"; 161257 [labelType="html" label="MapPartitionsRDD [161257] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } } 161233->161234; 161234->161235; 161235->161236; 161236->161253; 161253->161254; 161254->161255; 161255->161256; 161256->161257; }

161236

Event Timeline

Enable zooming