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

digraph G { subgraph clusterstage_785 { label="Stage 785"; 8242 [labelType="html" label="SQLExecutionRDD [8242] run at <unknown>:0"]; 8250 [labelType="html" label="SQLExecutionRDD [8250] toJavaRDD at <unknown>:0"]; 8252 [labelType="html" label="PythonRDD [8252] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster18437 { label="MicroBatchScan"; 8238 [labelType="html" label="DataSourceRDD [8238] run at <unknown>:0"]; 8239 [labelType="html" label="MapPartitionsRDD [8239] run at <unknown>:0"]; } subgraph cluster18436 { label="Project"; 8240 [labelType="html" label="MapPartitionsRDD [8240] run at <unknown>:0"]; } subgraph cluster18432 { label="WholeStageCodegen (1)"; 8241 [labelType="html" label="MapPartitionsRDD [8241] run at <unknown>:0"]; } subgraph cluster18446 { label="WholeStageCodegen (1)"; 8243 [labelType="html" label="MapPartitionsRDD [8243] toJavaRDD at <unknown>:0"]; } subgraph cluster18445 { label="Filter"; 8244 [labelType="html" label="MapPartitionsRDD [8244] toJavaRDD at <unknown>:0"]; } subgraph cluster18444 { label="Project"; 8245 [labelType="html" label="MapPartitionsRDD [8245] toJavaRDD at <unknown>:0"]; } subgraph cluster18441 { label="WholeStageCodegen (2)"; 8246 [labelType="html" label="MapPartitionsRDD [8246] toJavaRDD at <unknown>:0"]; } subgraph cluster18440 { label="Project"; 8247 [labelType="html" label="MapPartitionsRDD [8247] toJavaRDD at <unknown>:0"]; } subgraph cluster18439 { label="DeserializeToObject"; 8248 [labelType="html" label="MapPartitionsRDD [8248] toJavaRDD at <unknown>:0"]; } subgraph cluster18438 { label="MapPartitions"; 8249 [labelType="html" label="MapPartitionsRDD [8249] toJavaRDD at <unknown>:0"]; } subgraph cluster18448 { label="mapPartitions"; 8251 [labelType="html" label="MapPartitionsRDD [8251] toJavaRDD at <unknown>:0"]; } } 8238->8239; 8239->8240; 8240->8241; 8241->8242; 8242->8243; 8243->8244; 8244->8245; 8245->8246; 8246->8247; 8247->8248; 8248->8249; 8249->8250; 8250->8251; 8251->8252; }

Event Timeline

Enable zooming