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

digraph G { subgraph clusterstage_110 { label="Stage 110"; 1159 [labelType="html" label="SQLExecutionRDD [1159] run at <unknown>:0"]; 1167 [labelType="html" label="SQLExecutionRDD [1167] toJavaRDD at <unknown>:0"]; 1169 [labelType="html" label="PythonRDD [1169] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster2590 { label="MicroBatchScan"; 1155 [labelType="html" label="DataSourceRDD [1155] run at <unknown>:0"]; 1156 [labelType="html" label="MapPartitionsRDD [1156] run at <unknown>:0"]; } subgraph cluster2589 { label="Project"; 1157 [labelType="html" label="MapPartitionsRDD [1157] run at <unknown>:0"]; } subgraph cluster2585 { label="WholeStageCodegen (1)"; 1158 [labelType="html" label="MapPartitionsRDD [1158] run at <unknown>:0"]; } subgraph cluster2599 { label="WholeStageCodegen (1)"; 1160 [labelType="html" label="MapPartitionsRDD [1160] toJavaRDD at <unknown>:0"]; } subgraph cluster2598 { label="Filter"; 1161 [labelType="html" label="MapPartitionsRDD [1161] toJavaRDD at <unknown>:0"]; } subgraph cluster2597 { label="Project"; 1162 [labelType="html" label="MapPartitionsRDD [1162] toJavaRDD at <unknown>:0"]; } subgraph cluster2594 { label="WholeStageCodegen (2)"; 1163 [labelType="html" label="MapPartitionsRDD [1163] toJavaRDD at <unknown>:0"]; } subgraph cluster2593 { label="Project"; 1164 [labelType="html" label="MapPartitionsRDD [1164] toJavaRDD at <unknown>:0"]; } subgraph cluster2592 { label="DeserializeToObject"; 1165 [labelType="html" label="MapPartitionsRDD [1165] toJavaRDD at <unknown>:0"]; } subgraph cluster2591 { label="MapPartitions"; 1166 [labelType="html" label="MapPartitionsRDD [1166] toJavaRDD at <unknown>:0"]; } subgraph cluster2601 { label="mapPartitions"; 1168 [labelType="html" label="MapPartitionsRDD [1168] toJavaRDD at <unknown>:0"]; } } 1155->1156; 1156->1157; 1157->1158; 1158->1159; 1159->1160; 1160->1161; 1161->1162; 1162->1163; 1163->1164; 1164->1165; 1165->1166; 1166->1167; 1167->1168; 1168->1169; }

Event Timeline

Enable zooming