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

digraph G { subgraph clusterstage_777 { label="Stage 777"; 8158 [labelType="html" label="SQLExecutionRDD [8158] run at <unknown>:0"]; 8166 [labelType="html" label="SQLExecutionRDD [8166] toJavaRDD at <unknown>:0"]; 8168 [labelType="html" label="PythonRDD [8168] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster18249 { label="MicroBatchScan"; 8154 [labelType="html" label="DataSourceRDD [8154] run at <unknown>:0"]; 8155 [labelType="html" label="MapPartitionsRDD [8155] run at <unknown>:0"]; } subgraph cluster18248 { label="Project"; 8156 [labelType="html" label="MapPartitionsRDD [8156] run at <unknown>:0"]; } subgraph cluster18244 { label="WholeStageCodegen (1)"; 8157 [labelType="html" label="MapPartitionsRDD [8157] run at <unknown>:0"]; } subgraph cluster18258 { label="WholeStageCodegen (1)"; 8159 [labelType="html" label="MapPartitionsRDD [8159] toJavaRDD at <unknown>:0"]; } subgraph cluster18257 { label="Filter"; 8160 [labelType="html" label="MapPartitionsRDD [8160] toJavaRDD at <unknown>:0"]; } subgraph cluster18256 { label="Project"; 8161 [labelType="html" label="MapPartitionsRDD [8161] toJavaRDD at <unknown>:0"]; } subgraph cluster18253 { label="WholeStageCodegen (2)"; 8162 [labelType="html" label="MapPartitionsRDD [8162] toJavaRDD at <unknown>:0"]; } subgraph cluster18252 { label="Project"; 8163 [labelType="html" label="MapPartitionsRDD [8163] toJavaRDD at <unknown>:0"]; } subgraph cluster18251 { label="DeserializeToObject"; 8164 [labelType="html" label="MapPartitionsRDD [8164] toJavaRDD at <unknown>:0"]; } subgraph cluster18250 { label="MapPartitions"; 8165 [labelType="html" label="MapPartitionsRDD [8165] toJavaRDD at <unknown>:0"]; } subgraph cluster18260 { label="mapPartitions"; 8167 [labelType="html" label="MapPartitionsRDD [8167] toJavaRDD at <unknown>:0"]; } } 8154->8155; 8155->8156; 8156->8157; 8157->8158; 8158->8159; 8159->8160; 8160->8161; 8161->8162; 8162->8163; 8163->8164; 8164->8165; 8165->8166; 8166->8167; 8167->8168; }

Event Timeline

Enable zooming