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

digraph G { subgraph clusterstage_884 { label="Stage 884"; 9286 [labelType="html" label="SQLExecutionRDD [9286] run at <unknown>:0"]; 9294 [labelType="html" label="SQLExecutionRDD [9294] toJavaRDD at <unknown>:0"]; 9296 [labelType="html" label="PythonRDD [9296] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster20779 { label="MicroBatchScan"; 9282 [labelType="html" label="DataSourceRDD [9282] run at <unknown>:0"]; 9283 [labelType="html" label="MapPartitionsRDD [9283] run at <unknown>:0"]; } subgraph cluster20778 { label="Project"; 9284 [labelType="html" label="MapPartitionsRDD [9284] run at <unknown>:0"]; } subgraph cluster20774 { label="WholeStageCodegen (1)"; 9285 [labelType="html" label="MapPartitionsRDD [9285] run at <unknown>:0"]; } subgraph cluster20788 { label="WholeStageCodegen (1)"; 9287 [labelType="html" label="MapPartitionsRDD [9287] toJavaRDD at <unknown>:0"]; } subgraph cluster20787 { label="Filter"; 9288 [labelType="html" label="MapPartitionsRDD [9288] toJavaRDD at <unknown>:0"]; } subgraph cluster20786 { label="Project"; 9289 [labelType="html" label="MapPartitionsRDD [9289] toJavaRDD at <unknown>:0"]; } subgraph cluster20783 { label="WholeStageCodegen (2)"; 9290 [labelType="html" label="MapPartitionsRDD [9290] toJavaRDD at <unknown>:0"]; } subgraph cluster20782 { label="Project"; 9291 [labelType="html" label="MapPartitionsRDD [9291] toJavaRDD at <unknown>:0"]; } subgraph cluster20781 { label="DeserializeToObject"; 9292 [labelType="html" label="MapPartitionsRDD [9292] toJavaRDD at <unknown>:0"]; } subgraph cluster20780 { label="MapPartitions"; 9293 [labelType="html" label="MapPartitionsRDD [9293] toJavaRDD at <unknown>:0"]; } subgraph cluster20790 { label="mapPartitions"; 9295 [labelType="html" label="MapPartitionsRDD [9295] toJavaRDD at <unknown>:0"]; } } 9282->9283; 9283->9284; 9284->9285; 9285->9286; 9286->9287; 9287->9288; 9288->9289; 9289->9290; 9290->9291; 9291->9292; 9292->9293; 9293->9294; 9294->9295; 9295->9296; }

Event Timeline

Enable zooming