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

digraph G { subgraph clusterstage_1926 { label="Stage 1926"; 20227 [labelType="html" label="SQLExecutionRDD [20227] run at <unknown>:0"]; 20235 [labelType="html" label="SQLExecutionRDD [20235] toJavaRDD at <unknown>:0"]; 20237 [labelType="html" label="PythonRDD [20237] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster45266 { label="MicroBatchScan"; 20223 [labelType="html" label="DataSourceRDD [20223] run at <unknown>:0"]; 20224 [labelType="html" label="MapPartitionsRDD [20224] run at <unknown>:0"]; } subgraph cluster45265 { label="Project"; 20225 [labelType="html" label="MapPartitionsRDD [20225] run at <unknown>:0"]; } subgraph cluster45261 { label="WholeStageCodegen (1)"; 20226 [labelType="html" label="MapPartitionsRDD [20226] run at <unknown>:0"]; } subgraph cluster45275 { label="WholeStageCodegen (1)"; 20228 [labelType="html" label="MapPartitionsRDD [20228] toJavaRDD at <unknown>:0"]; } subgraph cluster45274 { label="Filter"; 20229 [labelType="html" label="MapPartitionsRDD [20229] toJavaRDD at <unknown>:0"]; } subgraph cluster45273 { label="Project"; 20230 [labelType="html" label="MapPartitionsRDD [20230] toJavaRDD at <unknown>:0"]; } subgraph cluster45270 { label="WholeStageCodegen (2)"; 20231 [labelType="html" label="MapPartitionsRDD [20231] toJavaRDD at <unknown>:0"]; } subgraph cluster45269 { label="Project"; 20232 [labelType="html" label="MapPartitionsRDD [20232] toJavaRDD at <unknown>:0"]; } subgraph cluster45268 { label="DeserializeToObject"; 20233 [labelType="html" label="MapPartitionsRDD [20233] toJavaRDD at <unknown>:0"]; } subgraph cluster45267 { label="MapPartitions"; 20234 [labelType="html" label="MapPartitionsRDD [20234] toJavaRDD at <unknown>:0"]; } subgraph cluster45277 { label="mapPartitions"; 20236 [labelType="html" label="MapPartitionsRDD [20236] toJavaRDD at <unknown>:0"]; } } 20223->20224; 20224->20225; 20225->20226; 20226->20227; 20227->20228; 20228->20229; 20229->20230; 20230->20231; 20231->20232; 20232->20233; 20233->20234; 20234->20235; 20235->20236; 20236->20237; }

Event Timeline

Enable zooming