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

digraph G { subgraph clusterstage_1645 { label="Stage 1645"; 17288 [labelType="html" label="SQLExecutionRDD [17288] run at <unknown>:0"]; 17296 [labelType="html" label="SQLExecutionRDD [17296] toJavaRDD at <unknown>:0"]; 17298 [labelType="html" label="PythonRDD [17298] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster38682 { label="MicroBatchScan"; 17284 [labelType="html" label="DataSourceRDD [17284] run at <unknown>:0"]; 17285 [labelType="html" label="MapPartitionsRDD [17285] run at <unknown>:0"]; } subgraph cluster38681 { label="Project"; 17286 [labelType="html" label="MapPartitionsRDD [17286] run at <unknown>:0"]; } subgraph cluster38677 { label="WholeStageCodegen (1)"; 17287 [labelType="html" label="MapPartitionsRDD [17287] run at <unknown>:0"]; } subgraph cluster38691 { label="WholeStageCodegen (1)"; 17289 [labelType="html" label="MapPartitionsRDD [17289] toJavaRDD at <unknown>:0"]; } subgraph cluster38690 { label="Filter"; 17290 [labelType="html" label="MapPartitionsRDD [17290] toJavaRDD at <unknown>:0"]; } subgraph cluster38689 { label="Project"; 17291 [labelType="html" label="MapPartitionsRDD [17291] toJavaRDD at <unknown>:0"]; } subgraph cluster38686 { label="WholeStageCodegen (2)"; 17292 [labelType="html" label="MapPartitionsRDD [17292] toJavaRDD at <unknown>:0"]; } subgraph cluster38685 { label="Project"; 17293 [labelType="html" label="MapPartitionsRDD [17293] toJavaRDD at <unknown>:0"]; } subgraph cluster38684 { label="DeserializeToObject"; 17294 [labelType="html" label="MapPartitionsRDD [17294] toJavaRDD at <unknown>:0"]; } subgraph cluster38683 { label="MapPartitions"; 17295 [labelType="html" label="MapPartitionsRDD [17295] toJavaRDD at <unknown>:0"]; } subgraph cluster38693 { label="mapPartitions"; 17297 [labelType="html" label="MapPartitionsRDD [17297] toJavaRDD at <unknown>:0"]; } } 17284->17285; 17285->17286; 17286->17287; 17287->17288; 17288->17289; 17289->17290; 17290->17291; 17291->17292; 17292->17293; 17293->17294; 17294->17295; 17295->17296; 17296->17297; 17297->17298; }

Event Timeline

Enable zooming