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

digraph G { subgraph clusterstage_125 { label="Stage 125"; 1306 [labelType="html" label="SQLExecutionRDD [1306] run at <unknown>:0"]; 1320 [labelType="html" label="SQLExecutionRDD [1320] toJavaRDD at <unknown>:0"]; 1322 [labelType="html" label="PythonRDD [1322] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster2919 { label="MicroBatchScan"; 1302 [labelType="html" label="DataSourceRDD [1302] run at <unknown>:0"]; 1303 [labelType="html" label="MapPartitionsRDD [1303] run at <unknown>:0"]; } subgraph cluster2918 { label="Project"; 1304 [labelType="html" label="MapPartitionsRDD [1304] run at <unknown>:0"]; } subgraph cluster2914 { label="WholeStageCodegen (1)"; 1305 [labelType="html" label="MapPartitionsRDD [1305] run at <unknown>:0"]; } subgraph cluster2936 { label="WholeStageCodegen (1)"; 1313 [labelType="html" label="MapPartitionsRDD [1313] toJavaRDD at <unknown>:0"]; } subgraph cluster2935 { label="Filter"; 1314 [labelType="html" label="MapPartitionsRDD [1314] toJavaRDD at <unknown>:0"]; } subgraph cluster2934 { label="Project"; 1315 [labelType="html" label="MapPartitionsRDD [1315] toJavaRDD at <unknown>:0"]; } subgraph cluster2931 { label="WholeStageCodegen (2)"; 1316 [labelType="html" label="MapPartitionsRDD [1316] toJavaRDD at <unknown>:0"]; } subgraph cluster2930 { label="Project"; 1317 [labelType="html" label="MapPartitionsRDD [1317] toJavaRDD at <unknown>:0"]; } subgraph cluster2929 { label="DeserializeToObject"; 1318 [labelType="html" label="MapPartitionsRDD [1318] toJavaRDD at <unknown>:0"]; } subgraph cluster2928 { label="MapPartitions"; 1319 [labelType="html" label="MapPartitionsRDD [1319] toJavaRDD at <unknown>:0"]; } subgraph cluster2938 { label="mapPartitions"; 1321 [labelType="html" label="MapPartitionsRDD [1321] toJavaRDD at <unknown>:0"]; } } 1302->1303; 1303->1304; 1304->1305; 1305->1306; 1306->1313; 1313->1314; 1314->1315; 1315->1316; 1316->1317; 1317->1318; 1318->1319; 1319->1320; 1320->1321; 1321->1322; }

Event Timeline

Enable zooming