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

digraph G { subgraph clusterstage_1925 { label="Stage 1925"; 20206 [labelType="html" label="SQLExecutionRDD [20206] run at <unknown>:0"]; 20220 [labelType="html" label="SQLExecutionRDD [20220] toJavaRDD at <unknown>:0"]; 20222 [labelType="html" label="PythonRDD [20222] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster45219 { label="MicroBatchScan"; 20202 [labelType="html" label="DataSourceRDD [20202] run at <unknown>:0"]; 20203 [labelType="html" label="MapPartitionsRDD [20203] run at <unknown>:0"]; } subgraph cluster45218 { label="Project"; 20204 [labelType="html" label="MapPartitionsRDD [20204] run at <unknown>:0"]; } subgraph cluster45214 { label="WholeStageCodegen (1)"; 20205 [labelType="html" label="MapPartitionsRDD [20205] run at <unknown>:0"]; } subgraph cluster45236 { label="WholeStageCodegen (1)"; 20213 [labelType="html" label="MapPartitionsRDD [20213] toJavaRDD at <unknown>:0"]; } subgraph cluster45235 { label="Filter"; 20214 [labelType="html" label="MapPartitionsRDD [20214] toJavaRDD at <unknown>:0"]; } subgraph cluster45234 { label="Project"; 20215 [labelType="html" label="MapPartitionsRDD [20215] toJavaRDD at <unknown>:0"]; } subgraph cluster45231 { label="WholeStageCodegen (2)"; 20216 [labelType="html" label="MapPartitionsRDD [20216] toJavaRDD at <unknown>:0"]; } subgraph cluster45230 { label="Project"; 20217 [labelType="html" label="MapPartitionsRDD [20217] toJavaRDD at <unknown>:0"]; } subgraph cluster45229 { label="DeserializeToObject"; 20218 [labelType="html" label="MapPartitionsRDD [20218] toJavaRDD at <unknown>:0"]; } subgraph cluster45228 { label="MapPartitions"; 20219 [labelType="html" label="MapPartitionsRDD [20219] toJavaRDD at <unknown>:0"]; } subgraph cluster45238 { label="mapPartitions"; 20221 [labelType="html" label="MapPartitionsRDD [20221] toJavaRDD at <unknown>:0"]; } } 20202->20203; 20203->20204; 20204->20205; 20205->20206; 20206->20213; 20213->20214; 20214->20215; 20215->20216; 20216->20217; 20217->20218; 20218->20219; 20219->20220; 20220->20221; 20221->20222; }

Event Timeline

Enable zooming