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

digraph G { subgraph clusterstage_120 { label="Stage 120"; 1264 [labelType="html" label="SQLExecutionRDD [1264] run at <unknown>:0"]; 1272 [labelType="html" label="SQLExecutionRDD [1272] toJavaRDD at <unknown>:0"]; 1274 [labelType="html" label="PythonRDD [1274] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster2825 { label="MicroBatchScan"; 1260 [labelType="html" label="DataSourceRDD [1260] run at <unknown>:0"]; 1261 [labelType="html" label="MapPartitionsRDD [1261] run at <unknown>:0"]; } subgraph cluster2824 { label="Project"; 1262 [labelType="html" label="MapPartitionsRDD [1262] run at <unknown>:0"]; } subgraph cluster2820 { label="WholeStageCodegen (1)"; 1263 [labelType="html" label="MapPartitionsRDD [1263] run at <unknown>:0"]; } subgraph cluster2834 { label="WholeStageCodegen (1)"; 1265 [labelType="html" label="MapPartitionsRDD [1265] toJavaRDD at <unknown>:0"]; } subgraph cluster2833 { label="Filter"; 1266 [labelType="html" label="MapPartitionsRDD [1266] toJavaRDD at <unknown>:0"]; } subgraph cluster2832 { label="Project"; 1267 [labelType="html" label="MapPartitionsRDD [1267] toJavaRDD at <unknown>:0"]; } subgraph cluster2829 { label="WholeStageCodegen (2)"; 1268 [labelType="html" label="MapPartitionsRDD [1268] toJavaRDD at <unknown>:0"]; } subgraph cluster2828 { label="Project"; 1269 [labelType="html" label="MapPartitionsRDD [1269] toJavaRDD at <unknown>:0"]; } subgraph cluster2827 { label="DeserializeToObject"; 1270 [labelType="html" label="MapPartitionsRDD [1270] toJavaRDD at <unknown>:0"]; } subgraph cluster2826 { label="MapPartitions"; 1271 [labelType="html" label="MapPartitionsRDD [1271] toJavaRDD at <unknown>:0"]; } subgraph cluster2836 { label="mapPartitions"; 1273 [labelType="html" label="MapPartitionsRDD [1273] toJavaRDD at <unknown>:0"]; } } 1260->1261; 1261->1262; 1262->1263; 1263->1264; 1264->1265; 1265->1266; 1266->1267; 1267->1268; 1268->1269; 1269->1270; 1270->1271; 1271->1272; 1272->1273; 1273->1274; }

Event Timeline

Enable zooming