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

digraph G { subgraph clusterstage_792 { label="Stage 792"; 8320 [labelType="html" label="SQLExecutionRDD [8320] run at <unknown>:0"]; 8328 [labelType="html" label="SQLExecutionRDD [8328] toJavaRDD at <unknown>:0"]; 8330 [labelType="html" label="PythonRDD [8330] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster18617 { label="MicroBatchScan"; 8316 [labelType="html" label="DataSourceRDD [8316] run at <unknown>:0"]; 8317 [labelType="html" label="MapPartitionsRDD [8317] run at <unknown>:0"]; } subgraph cluster18616 { label="Project"; 8318 [labelType="html" label="MapPartitionsRDD [8318] run at <unknown>:0"]; } subgraph cluster18612 { label="WholeStageCodegen (1)"; 8319 [labelType="html" label="MapPartitionsRDD [8319] run at <unknown>:0"]; } subgraph cluster18626 { label="WholeStageCodegen (1)"; 8321 [labelType="html" label="MapPartitionsRDD [8321] toJavaRDD at <unknown>:0"]; } subgraph cluster18625 { label="Filter"; 8322 [labelType="html" label="MapPartitionsRDD [8322] toJavaRDD at <unknown>:0"]; } subgraph cluster18624 { label="Project"; 8323 [labelType="html" label="MapPartitionsRDD [8323] toJavaRDD at <unknown>:0"]; } subgraph cluster18621 { label="WholeStageCodegen (2)"; 8324 [labelType="html" label="MapPartitionsRDD [8324] toJavaRDD at <unknown>:0"]; } subgraph cluster18620 { label="Project"; 8325 [labelType="html" label="MapPartitionsRDD [8325] toJavaRDD at <unknown>:0"]; } subgraph cluster18619 { label="DeserializeToObject"; 8326 [labelType="html" label="MapPartitionsRDD [8326] toJavaRDD at <unknown>:0"]; } subgraph cluster18618 { label="MapPartitions"; 8327 [labelType="html" label="MapPartitionsRDD [8327] toJavaRDD at <unknown>:0"]; } subgraph cluster18628 { label="mapPartitions"; 8329 [labelType="html" label="MapPartitionsRDD [8329] toJavaRDD at <unknown>:0"]; } } 8316->8317; 8317->8318; 8318->8319; 8319->8320; 8320->8321; 8321->8322; 8322->8323; 8323->8324; 8324->8325; 8325->8326; 8326->8327; 8327->8328; 8328->8329; 8329->8330; }

Event Timeline

Enable zooming