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

digraph G { subgraph clusterstage_122 { label="Stage 122"; 1285 [labelType="html" label="SQLExecutionRDD [1285] run at <unknown>:0"]; 1293 [labelType="html" label="SQLExecutionRDD [1293] toJavaRDD at <unknown>:0"]; 1295 [labelType="html" label="PythonRDD [1295] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster2872 { label="MicroBatchScan"; 1281 [labelType="html" label="DataSourceRDD [1281] run at <unknown>:0"]; 1282 [labelType="html" label="MapPartitionsRDD [1282] run at <unknown>:0"]; } subgraph cluster2871 { label="Project"; 1283 [labelType="html" label="MapPartitionsRDD [1283] run at <unknown>:0"]; } subgraph cluster2867 { label="WholeStageCodegen (1)"; 1284 [labelType="html" label="MapPartitionsRDD [1284] run at <unknown>:0"]; } subgraph cluster2881 { label="WholeStageCodegen (1)"; 1286 [labelType="html" label="MapPartitionsRDD [1286] toJavaRDD at <unknown>:0"]; } subgraph cluster2880 { label="Filter"; 1287 [labelType="html" label="MapPartitionsRDD [1287] toJavaRDD at <unknown>:0"]; } subgraph cluster2879 { label="Project"; 1288 [labelType="html" label="MapPartitionsRDD [1288] toJavaRDD at <unknown>:0"]; } subgraph cluster2876 { label="WholeStageCodegen (2)"; 1289 [labelType="html" label="MapPartitionsRDD [1289] toJavaRDD at <unknown>:0"]; } subgraph cluster2875 { label="Project"; 1290 [labelType="html" label="MapPartitionsRDD [1290] toJavaRDD at <unknown>:0"]; } subgraph cluster2874 { label="DeserializeToObject"; 1291 [labelType="html" label="MapPartitionsRDD [1291] toJavaRDD at <unknown>:0"]; } subgraph cluster2873 { label="MapPartitions"; 1292 [labelType="html" label="MapPartitionsRDD [1292] toJavaRDD at <unknown>:0"]; } subgraph cluster2883 { label="mapPartitions"; 1294 [labelType="html" label="MapPartitionsRDD [1294] toJavaRDD at <unknown>:0"]; } } 1281->1282; 1282->1283; 1283->1284; 1284->1285; 1285->1286; 1286->1287; 1287->1288; 1288->1289; 1289->1290; 1290->1291; 1291->1292; 1292->1293; 1293->1294; 1294->1295; }

Event Timeline

Enable zooming