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

digraph G { subgraph clusterstage_309 { label="Stage 309"; 3244 [labelType="html" label="SQLExecutionRDD [3244] run at <unknown>:0"]; 3252 [labelType="html" label="SQLExecutionRDD [3252] toJavaRDD at <unknown>:0"]; 3254 [labelType="html" label="PythonRDD [3254] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster7251 { label="MicroBatchScan"; 3240 [labelType="html" label="DataSourceRDD [3240] run at <unknown>:0"]; 3241 [labelType="html" label="MapPartitionsRDD [3241] run at <unknown>:0"]; } subgraph cluster7250 { label="Project"; 3242 [labelType="html" label="MapPartitionsRDD [3242] run at <unknown>:0"]; } subgraph cluster7246 { label="WholeStageCodegen (1)"; 3243 [labelType="html" label="MapPartitionsRDD [3243] run at <unknown>:0"]; } subgraph cluster7260 { label="WholeStageCodegen (1)"; 3245 [labelType="html" label="MapPartitionsRDD [3245] toJavaRDD at <unknown>:0"]; } subgraph cluster7259 { label="Filter"; 3246 [labelType="html" label="MapPartitionsRDD [3246] toJavaRDD at <unknown>:0"]; } subgraph cluster7258 { label="Project"; 3247 [labelType="html" label="MapPartitionsRDD [3247] toJavaRDD at <unknown>:0"]; } subgraph cluster7255 { label="WholeStageCodegen (2)"; 3248 [labelType="html" label="MapPartitionsRDD [3248] toJavaRDD at <unknown>:0"]; } subgraph cluster7254 { label="Project"; 3249 [labelType="html" label="MapPartitionsRDD [3249] toJavaRDD at <unknown>:0"]; } subgraph cluster7253 { label="DeserializeToObject"; 3250 [labelType="html" label="MapPartitionsRDD [3250] toJavaRDD at <unknown>:0"]; } subgraph cluster7252 { label="MapPartitions"; 3251 [labelType="html" label="MapPartitionsRDD [3251] toJavaRDD at <unknown>:0"]; } subgraph cluster7262 { label="mapPartitions"; 3253 [labelType="html" label="MapPartitionsRDD [3253] toJavaRDD at <unknown>:0"]; } } 3240->3241; 3241->3242; 3242->3243; 3243->3244; 3244->3245; 3245->3246; 3246->3247; 3247->3248; 3248->3249; 3249->3250; 3250->3251; 3251->3252; 3252->3253; 3253->3254; }

Event Timeline

Enable zooming