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

digraph G { subgraph clusterstage_330 { label="Stage 330"; 3469 [labelType="html" label="SQLExecutionRDD [3469] run at <unknown>:0"]; 3477 [labelType="html" label="SQLExecutionRDD [3477] toJavaRDD at <unknown>:0"]; 3479 [labelType="html" label="PythonRDD [3479] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster7760 { label="MicroBatchScan"; 3465 [labelType="html" label="DataSourceRDD [3465] run at <unknown>:0"]; 3466 [labelType="html" label="MapPartitionsRDD [3466] run at <unknown>:0"]; } subgraph cluster7759 { label="Project"; 3467 [labelType="html" label="MapPartitionsRDD [3467] run at <unknown>:0"]; } subgraph cluster7755 { label="WholeStageCodegen (1)"; 3468 [labelType="html" label="MapPartitionsRDD [3468] run at <unknown>:0"]; } subgraph cluster7769 { label="WholeStageCodegen (1)"; 3470 [labelType="html" label="MapPartitionsRDD [3470] toJavaRDD at <unknown>:0"]; } subgraph cluster7768 { label="Filter"; 3471 [labelType="html" label="MapPartitionsRDD [3471] toJavaRDD at <unknown>:0"]; } subgraph cluster7767 { label="Project"; 3472 [labelType="html" label="MapPartitionsRDD [3472] toJavaRDD at <unknown>:0"]; } subgraph cluster7764 { label="WholeStageCodegen (2)"; 3473 [labelType="html" label="MapPartitionsRDD [3473] toJavaRDD at <unknown>:0"]; } subgraph cluster7763 { label="Project"; 3474 [labelType="html" label="MapPartitionsRDD [3474] toJavaRDD at <unknown>:0"]; } subgraph cluster7762 { label="DeserializeToObject"; 3475 [labelType="html" label="MapPartitionsRDD [3475] toJavaRDD at <unknown>:0"]; } subgraph cluster7761 { label="MapPartitions"; 3476 [labelType="html" label="MapPartitionsRDD [3476] toJavaRDD at <unknown>:0"]; } subgraph cluster7771 { label="mapPartitions"; 3478 [labelType="html" label="MapPartitionsRDD [3478] toJavaRDD at <unknown>:0"]; } } 3465->3466; 3466->3467; 3467->3468; 3468->3469; 3469->3470; 3470->3471; 3471->3472; 3472->3473; 3473->3474; 3474->3475; 3475->3476; 3476->3477; 3477->3478; 3478->3479; }

Event Timeline

Enable zooming