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

digraph G { subgraph clusterstage_132 { label="Stage 132"; 1390 [labelType="html" label="SQLExecutionRDD [1390] run at <unknown>:0"]; 1398 [labelType="html" label="SQLExecutionRDD [1398] toJavaRDD at <unknown>:0"]; 1400 [labelType="html" label="PythonRDD [1400] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster3107 { label="MicroBatchScan"; 1386 [labelType="html" label="DataSourceRDD [1386] run at <unknown>:0"]; 1387 [labelType="html" label="MapPartitionsRDD [1387] run at <unknown>:0"]; } subgraph cluster3106 { label="Project"; 1388 [labelType="html" label="MapPartitionsRDD [1388] run at <unknown>:0"]; } subgraph cluster3102 { label="WholeStageCodegen (1)"; 1389 [labelType="html" label="MapPartitionsRDD [1389] run at <unknown>:0"]; } subgraph cluster3116 { label="WholeStageCodegen (1)"; 1391 [labelType="html" label="MapPartitionsRDD [1391] toJavaRDD at <unknown>:0"]; } subgraph cluster3115 { label="Filter"; 1392 [labelType="html" label="MapPartitionsRDD [1392] toJavaRDD at <unknown>:0"]; } subgraph cluster3114 { label="Project"; 1393 [labelType="html" label="MapPartitionsRDD [1393] toJavaRDD at <unknown>:0"]; } subgraph cluster3111 { label="WholeStageCodegen (2)"; 1394 [labelType="html" label="MapPartitionsRDD [1394] toJavaRDD at <unknown>:0"]; } subgraph cluster3110 { label="Project"; 1395 [labelType="html" label="MapPartitionsRDD [1395] toJavaRDD at <unknown>:0"]; } subgraph cluster3109 { label="DeserializeToObject"; 1396 [labelType="html" label="MapPartitionsRDD [1396] toJavaRDD at <unknown>:0"]; } subgraph cluster3108 { label="MapPartitions"; 1397 [labelType="html" label="MapPartitionsRDD [1397] toJavaRDD at <unknown>:0"]; } subgraph cluster3118 { label="mapPartitions"; 1399 [labelType="html" label="MapPartitionsRDD [1399] toJavaRDD at <unknown>:0"]; } } 1386->1387; 1387->1388; 1388->1389; 1389->1390; 1390->1391; 1391->1392; 1392->1393; 1393->1394; 1394->1395; 1395->1396; 1396->1397; 1397->1398; 1398->1399; 1399->1400; }

Event Timeline

Enable zooming