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

digraph G { subgraph clusterstage_560 { label="Stage 560"; 5884 [labelType="html" label="SQLExecutionRDD [5884] run at <unknown>:0"]; 5892 [labelType="html" label="SQLExecutionRDD [5892] toJavaRDD at <unknown>:0"]; 5894 [labelType="html" label="PythonRDD [5894] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster13165 { label="MicroBatchScan"; 5880 [labelType="html" label="DataSourceRDD [5880] run at <unknown>:0"]; 5881 [labelType="html" label="MapPartitionsRDD [5881] run at <unknown>:0"]; } subgraph cluster13164 { label="Project"; 5882 [labelType="html" label="MapPartitionsRDD [5882] run at <unknown>:0"]; } subgraph cluster13160 { label="WholeStageCodegen (1)"; 5883 [labelType="html" label="MapPartitionsRDD [5883] run at <unknown>:0"]; } subgraph cluster13174 { label="WholeStageCodegen (1)"; 5885 [labelType="html" label="MapPartitionsRDD [5885] toJavaRDD at <unknown>:0"]; } subgraph cluster13173 { label="Filter"; 5886 [labelType="html" label="MapPartitionsRDD [5886] toJavaRDD at <unknown>:0"]; } subgraph cluster13172 { label="Project"; 5887 [labelType="html" label="MapPartitionsRDD [5887] toJavaRDD at <unknown>:0"]; } subgraph cluster13169 { label="WholeStageCodegen (2)"; 5888 [labelType="html" label="MapPartitionsRDD [5888] toJavaRDD at <unknown>:0"]; } subgraph cluster13168 { label="Project"; 5889 [labelType="html" label="MapPartitionsRDD [5889] toJavaRDD at <unknown>:0"]; } subgraph cluster13167 { label="DeserializeToObject"; 5890 [labelType="html" label="MapPartitionsRDD [5890] toJavaRDD at <unknown>:0"]; } subgraph cluster13166 { label="MapPartitions"; 5891 [labelType="html" label="MapPartitionsRDD [5891] toJavaRDD at <unknown>:0"]; } subgraph cluster13176 { label="mapPartitions"; 5893 [labelType="html" label="MapPartitionsRDD [5893] toJavaRDD at <unknown>:0"]; } } 5880->5881; 5881->5882; 5882->5883; 5883->5884; 5884->5885; 5885->5886; 5886->5887; 5887->5888; 5888->5889; 5889->5890; 5890->5891; 5891->5892; 5892->5893; 5893->5894; }

Event Timeline

Enable zooming