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

digraph G { subgraph clusterstage_650 { label="Stage 650"; 6829 [labelType="html" label="SQLExecutionRDD [6829] run at <unknown>:0"]; 6837 [labelType="html" label="SQLExecutionRDD [6837] toJavaRDD at <unknown>:0"]; 6839 [labelType="html" label="PythonRDD [6839] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster15280 { label="MicroBatchScan"; 6825 [labelType="html" label="DataSourceRDD [6825] run at <unknown>:0"]; 6826 [labelType="html" label="MapPartitionsRDD [6826] run at <unknown>:0"]; } subgraph cluster15279 { label="Project"; 6827 [labelType="html" label="MapPartitionsRDD [6827] run at <unknown>:0"]; } subgraph cluster15275 { label="WholeStageCodegen (1)"; 6828 [labelType="html" label="MapPartitionsRDD [6828] run at <unknown>:0"]; } subgraph cluster15289 { label="WholeStageCodegen (1)"; 6830 [labelType="html" label="MapPartitionsRDD [6830] toJavaRDD at <unknown>:0"]; } subgraph cluster15288 { label="Filter"; 6831 [labelType="html" label="MapPartitionsRDD [6831] toJavaRDD at <unknown>:0"]; } subgraph cluster15287 { label="Project"; 6832 [labelType="html" label="MapPartitionsRDD [6832] toJavaRDD at <unknown>:0"]; } subgraph cluster15284 { label="WholeStageCodegen (2)"; 6833 [labelType="html" label="MapPartitionsRDD [6833] toJavaRDD at <unknown>:0"]; } subgraph cluster15283 { label="Project"; 6834 [labelType="html" label="MapPartitionsRDD [6834] toJavaRDD at <unknown>:0"]; } subgraph cluster15282 { label="DeserializeToObject"; 6835 [labelType="html" label="MapPartitionsRDD [6835] toJavaRDD at <unknown>:0"]; } subgraph cluster15281 { label="MapPartitions"; 6836 [labelType="html" label="MapPartitionsRDD [6836] toJavaRDD at <unknown>:0"]; } subgraph cluster15291 { label="mapPartitions"; 6838 [labelType="html" label="MapPartitionsRDD [6838] toJavaRDD at <unknown>:0"]; } } 6825->6826; 6826->6827; 6827->6828; 6828->6829; 6829->6830; 6830->6831; 6831->6832; 6832->6833; 6833->6834; 6834->6835; 6835->6836; 6836->6837; 6837->6838; 6838->6839; }

Event Timeline

Enable zooming