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

digraph G { subgraph clusterstage_1023 { label="Stage 1023"; 10757 [labelType="html" label="SQLExecutionRDD [10757] run at <unknown>:0"]; 10765 [labelType="html" label="SQLExecutionRDD [10765] toJavaRDD at <unknown>:0"]; 10767 [labelType="html" label="PythonRDD [10767] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster24065 { label="MicroBatchScan"; 10753 [labelType="html" label="DataSourceRDD [10753] run at <unknown>:0"]; 10754 [labelType="html" label="MapPartitionsRDD [10754] run at <unknown>:0"]; } subgraph cluster24064 { label="Project"; 10755 [labelType="html" label="MapPartitionsRDD [10755] run at <unknown>:0"]; } subgraph cluster24060 { label="WholeStageCodegen (1)"; 10756 [labelType="html" label="MapPartitionsRDD [10756] run at <unknown>:0"]; } subgraph cluster24074 { label="WholeStageCodegen (1)"; 10758 [labelType="html" label="MapPartitionsRDD [10758] toJavaRDD at <unknown>:0"]; } subgraph cluster24073 { label="Filter"; 10759 [labelType="html" label="MapPartitionsRDD [10759] toJavaRDD at <unknown>:0"]; } subgraph cluster24072 { label="Project"; 10760 [labelType="html" label="MapPartitionsRDD [10760] toJavaRDD at <unknown>:0"]; } subgraph cluster24069 { label="WholeStageCodegen (2)"; 10761 [labelType="html" label="MapPartitionsRDD [10761] toJavaRDD at <unknown>:0"]; } subgraph cluster24068 { label="Project"; 10762 [labelType="html" label="MapPartitionsRDD [10762] toJavaRDD at <unknown>:0"]; } subgraph cluster24067 { label="DeserializeToObject"; 10763 [labelType="html" label="MapPartitionsRDD [10763] toJavaRDD at <unknown>:0"]; } subgraph cluster24066 { label="MapPartitions"; 10764 [labelType="html" label="MapPartitionsRDD [10764] toJavaRDD at <unknown>:0"]; } subgraph cluster24076 { label="mapPartitions"; 10766 [labelType="html" label="MapPartitionsRDD [10766] toJavaRDD at <unknown>:0"]; } } 10753->10754; 10754->10755; 10755->10756; 10756->10757; 10757->10758; 10758->10759; 10759->10760; 10760->10761; 10761->10762; 10762->10763; 10763->10764; 10764->10765; 10765->10766; 10766->10767; }

Event Timeline

Enable zooming