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

digraph G { subgraph clusterstage_645 { label="Stage 645"; 6788 [labelType="html" label="SQLExecutionRDD [6788] run at <unknown>:0"]; 6796 [labelType="html" label="SQLExecutionRDD [6796] toJavaRDD at <unknown>:0"]; 6798 [labelType="html" label="PythonRDD [6798] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster15182 { label="MicroBatchScan"; 6784 [labelType="html" label="DataSourceRDD [6784] run at <unknown>:0"]; 6785 [labelType="html" label="MapPartitionsRDD [6785] run at <unknown>:0"]; } subgraph cluster15181 { label="Project"; 6786 [labelType="html" label="MapPartitionsRDD [6786] run at <unknown>:0"]; } subgraph cluster15177 { label="WholeStageCodegen (1)"; 6787 [labelType="html" label="MapPartitionsRDD [6787] run at <unknown>:0"]; } subgraph cluster15191 { label="WholeStageCodegen (1)"; 6789 [labelType="html" label="MapPartitionsRDD [6789] toJavaRDD at <unknown>:0"]; } subgraph cluster15190 { label="Filter"; 6790 [labelType="html" label="MapPartitionsRDD [6790] toJavaRDD at <unknown>:0"]; } subgraph cluster15189 { label="Project"; 6791 [labelType="html" label="MapPartitionsRDD [6791] toJavaRDD at <unknown>:0"]; } subgraph cluster15186 { label="WholeStageCodegen (2)"; 6792 [labelType="html" label="MapPartitionsRDD [6792] toJavaRDD at <unknown>:0"]; } subgraph cluster15185 { label="Project"; 6793 [labelType="html" label="MapPartitionsRDD [6793] toJavaRDD at <unknown>:0"]; } subgraph cluster15184 { label="DeserializeToObject"; 6794 [labelType="html" label="MapPartitionsRDD [6794] toJavaRDD at <unknown>:0"]; } subgraph cluster15183 { label="MapPartitions"; 6795 [labelType="html" label="MapPartitionsRDD [6795] toJavaRDD at <unknown>:0"]; } subgraph cluster15193 { label="mapPartitions"; 6797 [labelType="html" label="MapPartitionsRDD [6797] toJavaRDD at <unknown>:0"]; } } 6784->6785; 6785->6786; 6786->6787; 6787->6788; 6788->6789; 6789->6790; 6790->6791; 6791->6792; 6792->6793; 6793->6794; 6794->6795; 6795->6796; 6796->6797; 6797->6798; }

Event Timeline

Enable zooming