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

digraph G { subgraph clusterstage_840 { label="Stage 840"; 8824 [labelType="html" label="SQLExecutionRDD [8824] run at <unknown>:0"]; 8832 [labelType="html" label="SQLExecutionRDD [8832] toJavaRDD at <unknown>:0"]; 8834 [labelType="html" label="PythonRDD [8834] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster19745 { label="MicroBatchScan"; 8820 [labelType="html" label="DataSourceRDD [8820] run at <unknown>:0"]; 8821 [labelType="html" label="MapPartitionsRDD [8821] run at <unknown>:0"]; } subgraph cluster19744 { label="Project"; 8822 [labelType="html" label="MapPartitionsRDD [8822] run at <unknown>:0"]; } subgraph cluster19740 { label="WholeStageCodegen (1)"; 8823 [labelType="html" label="MapPartitionsRDD [8823] run at <unknown>:0"]; } subgraph cluster19754 { label="WholeStageCodegen (1)"; 8825 [labelType="html" label="MapPartitionsRDD [8825] toJavaRDD at <unknown>:0"]; } subgraph cluster19753 { label="Filter"; 8826 [labelType="html" label="MapPartitionsRDD [8826] toJavaRDD at <unknown>:0"]; } subgraph cluster19752 { label="Project"; 8827 [labelType="html" label="MapPartitionsRDD [8827] toJavaRDD at <unknown>:0"]; } subgraph cluster19749 { label="WholeStageCodegen (2)"; 8828 [labelType="html" label="MapPartitionsRDD [8828] toJavaRDD at <unknown>:0"]; } subgraph cluster19748 { label="Project"; 8829 [labelType="html" label="MapPartitionsRDD [8829] toJavaRDD at <unknown>:0"]; } subgraph cluster19747 { label="DeserializeToObject"; 8830 [labelType="html" label="MapPartitionsRDD [8830] toJavaRDD at <unknown>:0"]; } subgraph cluster19746 { label="MapPartitions"; 8831 [labelType="html" label="MapPartitionsRDD [8831] toJavaRDD at <unknown>:0"]; } subgraph cluster19756 { label="mapPartitions"; 8833 [labelType="html" label="MapPartitionsRDD [8833] toJavaRDD at <unknown>:0"]; } } 8820->8821; 8821->8822; 8822->8823; 8823->8824; 8824->8825; 8825->8826; 8826->8827; 8827->8828; 8828->8829; 8829->8830; 8830->8831; 8831->8832; 8832->8833; 8833->8834; }

Event Timeline

Enable zooming