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

digraph G { subgraph clusterstage_118 { label="Stage 118"; 1243 [labelType="html" label="SQLExecutionRDD [1243] run at <unknown>:0"]; 1251 [labelType="html" label="SQLExecutionRDD [1251] toJavaRDD at <unknown>:0"]; 1253 [labelType="html" label="PythonRDD [1253] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster2778 { label="MicroBatchScan"; 1239 [labelType="html" label="DataSourceRDD [1239] run at <unknown>:0"]; 1240 [labelType="html" label="MapPartitionsRDD [1240] run at <unknown>:0"]; } subgraph cluster2777 { label="Project"; 1241 [labelType="html" label="MapPartitionsRDD [1241] run at <unknown>:0"]; } subgraph cluster2773 { label="WholeStageCodegen (1)"; 1242 [labelType="html" label="MapPartitionsRDD [1242] run at <unknown>:0"]; } subgraph cluster2787 { label="WholeStageCodegen (1)"; 1244 [labelType="html" label="MapPartitionsRDD [1244] toJavaRDD at <unknown>:0"]; } subgraph cluster2786 { label="Filter"; 1245 [labelType="html" label="MapPartitionsRDD [1245] toJavaRDD at <unknown>:0"]; } subgraph cluster2785 { label="Project"; 1246 [labelType="html" label="MapPartitionsRDD [1246] toJavaRDD at <unknown>:0"]; } subgraph cluster2782 { label="WholeStageCodegen (2)"; 1247 [labelType="html" label="MapPartitionsRDD [1247] toJavaRDD at <unknown>:0"]; } subgraph cluster2781 { label="Project"; 1248 [labelType="html" label="MapPartitionsRDD [1248] toJavaRDD at <unknown>:0"]; } subgraph cluster2780 { label="DeserializeToObject"; 1249 [labelType="html" label="MapPartitionsRDD [1249] toJavaRDD at <unknown>:0"]; } subgraph cluster2779 { label="MapPartitions"; 1250 [labelType="html" label="MapPartitionsRDD [1250] toJavaRDD at <unknown>:0"]; } subgraph cluster2789 { label="mapPartitions"; 1252 [labelType="html" label="MapPartitionsRDD [1252] toJavaRDD at <unknown>:0"]; } } 1239->1240; 1240->1241; 1241->1242; 1242->1243; 1243->1244; 1244->1245; 1245->1246; 1246->1247; 1247->1248; 1248->1249; 1249->1250; 1250->1251; 1251->1252; 1252->1253; }

Event Timeline

Enable zooming