processing-stream-kafka-raw-to-minio - Details for Stage 152 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 3
Input Size / Records: 0.0 B / 460
Associated Job Ids: 152

digraph G { subgraph clusterstage_152 { label="Stage 152"; 1600 [labelType="html" label="SQLExecutionRDD [1600] run at <unknown>:0"]; 1608 [labelType="html" label="SQLExecutionRDD [1608] toJavaRDD at <unknown>:0"]; 1610 [labelType="html" label="PythonRDD [1610] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster3577 { label="MicroBatchScan"; 1596 [labelType="html" label="DataSourceRDD [1596] run at <unknown>:0"]; 1597 [labelType="html" label="MapPartitionsRDD [1597] run at <unknown>:0"]; } subgraph cluster3576 { label="Project"; 1598 [labelType="html" label="MapPartitionsRDD [1598] run at <unknown>:0"]; } subgraph cluster3572 { label="WholeStageCodegen (1)"; 1599 [labelType="html" label="MapPartitionsRDD [1599] run at <unknown>:0"]; } subgraph cluster3586 { label="WholeStageCodegen (1)"; 1601 [labelType="html" label="MapPartitionsRDD [1601] toJavaRDD at <unknown>:0"]; } subgraph cluster3585 { label="Filter"; 1602 [labelType="html" label="MapPartitionsRDD [1602] toJavaRDD at <unknown>:0"]; } subgraph cluster3584 { label="Project"; 1603 [labelType="html" label="MapPartitionsRDD [1603] toJavaRDD at <unknown>:0"]; } subgraph cluster3581 { label="WholeStageCodegen (2)"; 1604 [labelType="html" label="MapPartitionsRDD [1604] toJavaRDD at <unknown>:0"]; } subgraph cluster3580 { label="Project"; 1605 [labelType="html" label="MapPartitionsRDD [1605] toJavaRDD at <unknown>:0"]; } subgraph cluster3579 { label="DeserializeToObject"; 1606 [labelType="html" label="MapPartitionsRDD [1606] toJavaRDD at <unknown>:0"]; } subgraph cluster3578 { label="MapPartitions"; 1607 [labelType="html" label="MapPartitionsRDD [1607] toJavaRDD at <unknown>:0"]; } subgraph cluster3588 { label="mapPartitions"; 1609 [labelType="html" label="MapPartitionsRDD [1609] toJavaRDD at <unknown>:0"]; } } 1596->1597; 1597->1598; 1598->1599; 1599->1600; 1600->1601; 1601->1602; 1602->1603; 1603->1604; 1604->1605; 1605->1606; 1606->1607; 1607->1608; 1608->1609; 1609->1610; }

Event Timeline

Enable zooming