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

digraph G { subgraph clusterstage_1920 { label="Stage 1920"; 20164 [labelType="html" label="SQLExecutionRDD [20164] run at <unknown>:0"]; 20172 [labelType="html" label="SQLExecutionRDD [20172] toJavaRDD at <unknown>:0"]; 20174 [labelType="html" label="PythonRDD [20174] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster45125 { label="MicroBatchScan"; 20160 [labelType="html" label="DataSourceRDD [20160] run at <unknown>:0"]; 20161 [labelType="html" label="MapPartitionsRDD [20161] run at <unknown>:0"]; } subgraph cluster45124 { label="Project"; 20162 [labelType="html" label="MapPartitionsRDD [20162] run at <unknown>:0"]; } subgraph cluster45120 { label="WholeStageCodegen (1)"; 20163 [labelType="html" label="MapPartitionsRDD [20163] run at <unknown>:0"]; } subgraph cluster45134 { label="WholeStageCodegen (1)"; 20165 [labelType="html" label="MapPartitionsRDD [20165] toJavaRDD at <unknown>:0"]; } subgraph cluster45133 { label="Filter"; 20166 [labelType="html" label="MapPartitionsRDD [20166] toJavaRDD at <unknown>:0"]; } subgraph cluster45132 { label="Project"; 20167 [labelType="html" label="MapPartitionsRDD [20167] toJavaRDD at <unknown>:0"]; } subgraph cluster45129 { label="WholeStageCodegen (2)"; 20168 [labelType="html" label="MapPartitionsRDD [20168] toJavaRDD at <unknown>:0"]; } subgraph cluster45128 { label="Project"; 20169 [labelType="html" label="MapPartitionsRDD [20169] toJavaRDD at <unknown>:0"]; } subgraph cluster45127 { label="DeserializeToObject"; 20170 [labelType="html" label="MapPartitionsRDD [20170] toJavaRDD at <unknown>:0"]; } subgraph cluster45126 { label="MapPartitions"; 20171 [labelType="html" label="MapPartitionsRDD [20171] toJavaRDD at <unknown>:0"]; } subgraph cluster45136 { label="mapPartitions"; 20173 [labelType="html" label="MapPartitionsRDD [20173] toJavaRDD at <unknown>:0"]; } } 20160->20161; 20161->20162; 20162->20163; 20163->20164; 20164->20165; 20165->20166; 20166->20167; 20167->20168; 20168->20169; 20169->20170; 20170->20171; 20171->20172; 20172->20173; 20173->20174; }

Event Timeline

Enable zooming