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

digraph G { subgraph clusterstage_946 { label="Stage 946"; 9938 [labelType="html" label="SQLExecutionRDD [9938] run at <unknown>:0"]; 9952 [labelType="html" label="SQLExecutionRDD [9952] toJavaRDD at <unknown>:0"]; 9954 [labelType="html" label="PythonRDD [9954] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster22232 { label="MicroBatchScan"; 9934 [labelType="html" label="DataSourceRDD [9934] run at <unknown>:0"]; 9935 [labelType="html" label="MapPartitionsRDD [9935] run at <unknown>:0"]; } subgraph cluster22231 { label="Project"; 9936 [labelType="html" label="MapPartitionsRDD [9936] run at <unknown>:0"]; } subgraph cluster22227 { label="WholeStageCodegen (1)"; 9937 [labelType="html" label="MapPartitionsRDD [9937] run at <unknown>:0"]; } subgraph cluster22249 { label="WholeStageCodegen (1)"; 9945 [labelType="html" label="MapPartitionsRDD [9945] toJavaRDD at <unknown>:0"]; } subgraph cluster22248 { label="Filter"; 9946 [labelType="html" label="MapPartitionsRDD [9946] toJavaRDD at <unknown>:0"]; } subgraph cluster22247 { label="Project"; 9947 [labelType="html" label="MapPartitionsRDD [9947] toJavaRDD at <unknown>:0"]; } subgraph cluster22244 { label="WholeStageCodegen (2)"; 9948 [labelType="html" label="MapPartitionsRDD [9948] toJavaRDD at <unknown>:0"]; } subgraph cluster22243 { label="Project"; 9949 [labelType="html" label="MapPartitionsRDD [9949] toJavaRDD at <unknown>:0"]; } subgraph cluster22242 { label="DeserializeToObject"; 9950 [labelType="html" label="MapPartitionsRDD [9950] toJavaRDD at <unknown>:0"]; } subgraph cluster22241 { label="MapPartitions"; 9951 [labelType="html" label="MapPartitionsRDD [9951] toJavaRDD at <unknown>:0"]; } subgraph cluster22251 { label="mapPartitions"; 9953 [labelType="html" label="MapPartitionsRDD [9953] toJavaRDD at <unknown>:0"]; } } 9934->9935; 9935->9936; 9936->9937; 9937->9938; 9938->9945; 9945->9946; 9946->9947; 9947->9948; 9948->9949; 9949->9950; 9950->9951; 9951->9952; 9952->9953; 9953->9954; }

Event Timeline

Enable zooming