processing-stream-kafka-raw-to-minio - Details for Stage 157 (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 / 478
Associated Job Ids: 157

digraph G { subgraph clusterstage_157 { label="Stage 157"; 1642 [labelType="html" label="SQLExecutionRDD [1642] run at <unknown>:0"]; 1656 [labelType="html" label="SQLExecutionRDD [1656] toJavaRDD at <unknown>:0"]; 1658 [labelType="html" label="PythonRDD [1658] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster3671 { label="MicroBatchScan"; 1638 [labelType="html" label="DataSourceRDD [1638] run at <unknown>:0"]; 1639 [labelType="html" label="MapPartitionsRDD [1639] run at <unknown>:0"]; } subgraph cluster3670 { label="Project"; 1640 [labelType="html" label="MapPartitionsRDD [1640] run at <unknown>:0"]; } subgraph cluster3666 { label="WholeStageCodegen (1)"; 1641 [labelType="html" label="MapPartitionsRDD [1641] run at <unknown>:0"]; } subgraph cluster3688 { label="WholeStageCodegen (1)"; 1649 [labelType="html" label="MapPartitionsRDD [1649] toJavaRDD at <unknown>:0"]; } subgraph cluster3687 { label="Filter"; 1650 [labelType="html" label="MapPartitionsRDD [1650] toJavaRDD at <unknown>:0"]; } subgraph cluster3686 { label="Project"; 1651 [labelType="html" label="MapPartitionsRDD [1651] toJavaRDD at <unknown>:0"]; } subgraph cluster3683 { label="WholeStageCodegen (2)"; 1652 [labelType="html" label="MapPartitionsRDD [1652] toJavaRDD at <unknown>:0"]; } subgraph cluster3682 { label="Project"; 1653 [labelType="html" label="MapPartitionsRDD [1653] toJavaRDD at <unknown>:0"]; } subgraph cluster3681 { label="DeserializeToObject"; 1654 [labelType="html" label="MapPartitionsRDD [1654] toJavaRDD at <unknown>:0"]; } subgraph cluster3680 { label="MapPartitions"; 1655 [labelType="html" label="MapPartitionsRDD [1655] toJavaRDD at <unknown>:0"]; } subgraph cluster3690 { label="mapPartitions"; 1657 [labelType="html" label="MapPartitionsRDD [1657] toJavaRDD at <unknown>:0"]; } } 1638->1639; 1639->1640; 1640->1641; 1641->1642; 1642->1649; 1649->1650; 1650->1651; 1651->1652; 1652->1653; 1653->1654; 1654->1655; 1655->1656; 1656->1657; 1657->1658; }

Event Timeline

Enable zooming