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

digraph G { subgraph clusterstage_788 { label="Stage 788"; 8278 [labelType="html" label="SQLExecutionRDD [8278] run at <unknown>:0"]; 8286 [labelType="html" label="SQLExecutionRDD [8286] toJavaRDD at <unknown>:0"]; 8288 [labelType="html" label="PythonRDD [8288] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster18523 { label="MicroBatchScan"; 8274 [labelType="html" label="DataSourceRDD [8274] run at <unknown>:0"]; 8275 [labelType="html" label="MapPartitionsRDD [8275] run at <unknown>:0"]; } subgraph cluster18522 { label="Project"; 8276 [labelType="html" label="MapPartitionsRDD [8276] run at <unknown>:0"]; } subgraph cluster18518 { label="WholeStageCodegen (1)"; 8277 [labelType="html" label="MapPartitionsRDD [8277] run at <unknown>:0"]; } subgraph cluster18532 { label="WholeStageCodegen (1)"; 8279 [labelType="html" label="MapPartitionsRDD [8279] toJavaRDD at <unknown>:0"]; } subgraph cluster18531 { label="Filter"; 8280 [labelType="html" label="MapPartitionsRDD [8280] toJavaRDD at <unknown>:0"]; } subgraph cluster18530 { label="Project"; 8281 [labelType="html" label="MapPartitionsRDD [8281] toJavaRDD at <unknown>:0"]; } subgraph cluster18527 { label="WholeStageCodegen (2)"; 8282 [labelType="html" label="MapPartitionsRDD [8282] toJavaRDD at <unknown>:0"]; } subgraph cluster18526 { label="Project"; 8283 [labelType="html" label="MapPartitionsRDD [8283] toJavaRDD at <unknown>:0"]; } subgraph cluster18525 { label="DeserializeToObject"; 8284 [labelType="html" label="MapPartitionsRDD [8284] toJavaRDD at <unknown>:0"]; } subgraph cluster18524 { label="MapPartitions"; 8285 [labelType="html" label="MapPartitionsRDD [8285] toJavaRDD at <unknown>:0"]; } subgraph cluster18534 { label="mapPartitions"; 8287 [labelType="html" label="MapPartitionsRDD [8287] toJavaRDD at <unknown>:0"]; } } 8274->8275; 8275->8276; 8276->8277; 8277->8278; 8278->8279; 8279->8280; 8280->8281; 8281->8282; 8282->8283; 8283->8284; 8284->8285; 8285->8286; 8286->8287; 8287->8288; }

Event Timeline

Enable zooming