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

digraph G { subgraph clusterstage_941 { label="Stage 941"; 9896 [labelType="html" label="SQLExecutionRDD [9896] run at <unknown>:0"]; 9904 [labelType="html" label="SQLExecutionRDD [9904] toJavaRDD at <unknown>:0"]; 9906 [labelType="html" label="PythonRDD [9906] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster22138 { label="MicroBatchScan"; 9892 [labelType="html" label="DataSourceRDD [9892] run at <unknown>:0"]; 9893 [labelType="html" label="MapPartitionsRDD [9893] run at <unknown>:0"]; } subgraph cluster22137 { label="Project"; 9894 [labelType="html" label="MapPartitionsRDD [9894] run at <unknown>:0"]; } subgraph cluster22133 { label="WholeStageCodegen (1)"; 9895 [labelType="html" label="MapPartitionsRDD [9895] run at <unknown>:0"]; } subgraph cluster22147 { label="WholeStageCodegen (1)"; 9897 [labelType="html" label="MapPartitionsRDD [9897] toJavaRDD at <unknown>:0"]; } subgraph cluster22146 { label="Filter"; 9898 [labelType="html" label="MapPartitionsRDD [9898] toJavaRDD at <unknown>:0"]; } subgraph cluster22145 { label="Project"; 9899 [labelType="html" label="MapPartitionsRDD [9899] toJavaRDD at <unknown>:0"]; } subgraph cluster22142 { label="WholeStageCodegen (2)"; 9900 [labelType="html" label="MapPartitionsRDD [9900] toJavaRDD at <unknown>:0"]; } subgraph cluster22141 { label="Project"; 9901 [labelType="html" label="MapPartitionsRDD [9901] toJavaRDD at <unknown>:0"]; } subgraph cluster22140 { label="DeserializeToObject"; 9902 [labelType="html" label="MapPartitionsRDD [9902] toJavaRDD at <unknown>:0"]; } subgraph cluster22139 { label="MapPartitions"; 9903 [labelType="html" label="MapPartitionsRDD [9903] toJavaRDD at <unknown>:0"]; } subgraph cluster22149 { label="mapPartitions"; 9905 [labelType="html" label="MapPartitionsRDD [9905] toJavaRDD at <unknown>:0"]; } } 9892->9893; 9893->9894; 9894->9895; 9895->9896; 9896->9897; 9897->9898; 9898->9899; 9899->9900; 9900->9901; 9901->9902; 9902->9903; 9903->9904; 9904->9905; 9905->9906; }

Event Timeline

Enable zooming