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

digraph G { subgraph clusterstage_155 { label="Stage 155"; 1627 [labelType="html" label="SQLExecutionRDD [1627] run at <unknown>:0"]; 1635 [labelType="html" label="SQLExecutionRDD [1635] toJavaRDD at <unknown>:0"]; 1637 [labelType="html" label="PythonRDD [1637] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster3632 { label="MicroBatchScan"; 1623 [labelType="html" label="DataSourceRDD [1623] run at <unknown>:0"]; 1624 [labelType="html" label="MapPartitionsRDD [1624] run at <unknown>:0"]; } subgraph cluster3631 { label="Project"; 1625 [labelType="html" label="MapPartitionsRDD [1625] run at <unknown>:0"]; } subgraph cluster3625 { label="WholeStageCodegen (1)"; 1626 [labelType="html" label="MapPartitionsRDD [1626] run at <unknown>:0"]; } subgraph cluster3641 { label="WholeStageCodegen (1)"; 1628 [labelType="html" label="MapPartitionsRDD [1628] toJavaRDD at <unknown>:0"]; } subgraph cluster3640 { label="Filter"; 1629 [labelType="html" label="MapPartitionsRDD [1629] toJavaRDD at <unknown>:0"]; } subgraph cluster3639 { label="Project"; 1630 [labelType="html" label="MapPartitionsRDD [1630] toJavaRDD at <unknown>:0"]; } subgraph cluster3636 { label="WholeStageCodegen (2)"; 1631 [labelType="html" label="MapPartitionsRDD [1631] toJavaRDD at <unknown>:0"]; } subgraph cluster3635 { label="Project"; 1632 [labelType="html" label="MapPartitionsRDD [1632] toJavaRDD at <unknown>:0"]; } subgraph cluster3634 { label="DeserializeToObject"; 1633 [labelType="html" label="MapPartitionsRDD [1633] toJavaRDD at <unknown>:0"]; } subgraph cluster3633 { label="MapPartitions"; 1634 [labelType="html" label="MapPartitionsRDD [1634] toJavaRDD at <unknown>:0"]; } subgraph cluster3643 { label="mapPartitions"; 1636 [labelType="html" label="MapPartitionsRDD [1636] toJavaRDD at <unknown>:0"]; } } 1623->1624; 1624->1625; 1625->1626; 1626->1627; 1627->1628; 1628->1629; 1629->1630; 1630->1631; 1631->1632; 1632->1633; 1633->1634; 1634->1635; 1635->1636; 1636->1637; }

Event Timeline

Enable zooming