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

digraph G { subgraph clusterstage_434 { label="Stage 434"; 4561 [labelType="html" label="SQLExecutionRDD [4561] run at <unknown>:0"]; 4569 [labelType="html" label="SQLExecutionRDD [4569] toJavaRDD at <unknown>:0"]; 4571 [labelType="html" label="PythonRDD [4571] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster10204 { label="MicroBatchScan"; 4557 [labelType="html" label="DataSourceRDD [4557] run at <unknown>:0"]; 4558 [labelType="html" label="MapPartitionsRDD [4558] run at <unknown>:0"]; } subgraph cluster10203 { label="Project"; 4559 [labelType="html" label="MapPartitionsRDD [4559] run at <unknown>:0"]; } subgraph cluster10199 { label="WholeStageCodegen (1)"; 4560 [labelType="html" label="MapPartitionsRDD [4560] run at <unknown>:0"]; } subgraph cluster10213 { label="WholeStageCodegen (1)"; 4562 [labelType="html" label="MapPartitionsRDD [4562] toJavaRDD at <unknown>:0"]; } subgraph cluster10212 { label="Filter"; 4563 [labelType="html" label="MapPartitionsRDD [4563] toJavaRDD at <unknown>:0"]; } subgraph cluster10211 { label="Project"; 4564 [labelType="html" label="MapPartitionsRDD [4564] toJavaRDD at <unknown>:0"]; } subgraph cluster10208 { label="WholeStageCodegen (2)"; 4565 [labelType="html" label="MapPartitionsRDD [4565] toJavaRDD at <unknown>:0"]; } subgraph cluster10207 { label="Project"; 4566 [labelType="html" label="MapPartitionsRDD [4566] toJavaRDD at <unknown>:0"]; } subgraph cluster10206 { label="DeserializeToObject"; 4567 [labelType="html" label="MapPartitionsRDD [4567] toJavaRDD at <unknown>:0"]; } subgraph cluster10205 { label="MapPartitions"; 4568 [labelType="html" label="MapPartitionsRDD [4568] toJavaRDD at <unknown>:0"]; } subgraph cluster10215 { label="mapPartitions"; 4570 [labelType="html" label="MapPartitionsRDD [4570] toJavaRDD at <unknown>:0"]; } } 4557->4558; 4558->4559; 4559->4560; 4560->4561; 4561->4562; 4562->4563; 4563->4564; 4564->4565; 4565->4566; 4566->4567; 4567->4568; 4568->4569; 4569->4570; 4570->4571; }

Event Timeline

Enable zooming