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

digraph G { subgraph clusterstage_1641 { label="Stage 1641"; 17246 [labelType="html" label="SQLExecutionRDD [17246] run at <unknown>:0"]; 17254 [labelType="html" label="SQLExecutionRDD [17254] toJavaRDD at <unknown>:0"]; 17256 [labelType="html" label="PythonRDD [17256] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster38588 { label="MicroBatchScan"; 17242 [labelType="html" label="DataSourceRDD [17242] run at <unknown>:0"]; 17243 [labelType="html" label="MapPartitionsRDD [17243] run at <unknown>:0"]; } subgraph cluster38587 { label="Project"; 17244 [labelType="html" label="MapPartitionsRDD [17244] run at <unknown>:0"]; } subgraph cluster38583 { label="WholeStageCodegen (1)"; 17245 [labelType="html" label="MapPartitionsRDD [17245] run at <unknown>:0"]; } subgraph cluster38597 { label="WholeStageCodegen (1)"; 17247 [labelType="html" label="MapPartitionsRDD [17247] toJavaRDD at <unknown>:0"]; } subgraph cluster38596 { label="Filter"; 17248 [labelType="html" label="MapPartitionsRDD [17248] toJavaRDD at <unknown>:0"]; } subgraph cluster38595 { label="Project"; 17249 [labelType="html" label="MapPartitionsRDD [17249] toJavaRDD at <unknown>:0"]; } subgraph cluster38592 { label="WholeStageCodegen (2)"; 17250 [labelType="html" label="MapPartitionsRDD [17250] toJavaRDD at <unknown>:0"]; } subgraph cluster38591 { label="Project"; 17251 [labelType="html" label="MapPartitionsRDD [17251] toJavaRDD at <unknown>:0"]; } subgraph cluster38590 { label="DeserializeToObject"; 17252 [labelType="html" label="MapPartitionsRDD [17252] toJavaRDD at <unknown>:0"]; } subgraph cluster38589 { label="MapPartitions"; 17253 [labelType="html" label="MapPartitionsRDD [17253] toJavaRDD at <unknown>:0"]; } subgraph cluster38599 { label="mapPartitions"; 17255 [labelType="html" label="MapPartitionsRDD [17255] toJavaRDD at <unknown>:0"]; } } 17242->17243; 17243->17244; 17244->17245; 17245->17246; 17246->17247; 17247->17248; 17248->17249; 17249->17250; 17250->17251; 17251->17252; 17252->17253; 17253->17254; 17254->17255; 17255->17256; }

Event Timeline

Enable zooming