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

digraph G { subgraph clusterstage_2053 { label="Stage 2053"; 21572 [labelType="html" label="SQLExecutionRDD [21572] run at <unknown>:0"]; 21580 [labelType="html" label="SQLExecutionRDD [21580] toJavaRDD at <unknown>:0"]; 21582 [labelType="html" label="PythonRDD [21582] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster48270 { label="MicroBatchScan"; 21568 [labelType="html" label="DataSourceRDD [21568] run at <unknown>:0"]; 21569 [labelType="html" label="MapPartitionsRDD [21569] run at <unknown>:0"]; } subgraph cluster48269 { label="Project"; 21570 [labelType="html" label="MapPartitionsRDD [21570] run at <unknown>:0"]; } subgraph cluster48265 { label="WholeStageCodegen (1)"; 21571 [labelType="html" label="MapPartitionsRDD [21571] run at <unknown>:0"]; } subgraph cluster48279 { label="WholeStageCodegen (1)"; 21573 [labelType="html" label="MapPartitionsRDD [21573] toJavaRDD at <unknown>:0"]; } subgraph cluster48278 { label="Filter"; 21574 [labelType="html" label="MapPartitionsRDD [21574] toJavaRDD at <unknown>:0"]; } subgraph cluster48277 { label="Project"; 21575 [labelType="html" label="MapPartitionsRDD [21575] toJavaRDD at <unknown>:0"]; } subgraph cluster48274 { label="WholeStageCodegen (2)"; 21576 [labelType="html" label="MapPartitionsRDD [21576] toJavaRDD at <unknown>:0"]; } subgraph cluster48273 { label="Project"; 21577 [labelType="html" label="MapPartitionsRDD [21577] toJavaRDD at <unknown>:0"]; } subgraph cluster48272 { label="DeserializeToObject"; 21578 [labelType="html" label="MapPartitionsRDD [21578] toJavaRDD at <unknown>:0"]; } subgraph cluster48271 { label="MapPartitions"; 21579 [labelType="html" label="MapPartitionsRDD [21579] toJavaRDD at <unknown>:0"]; } subgraph cluster48281 { label="mapPartitions"; 21581 [labelType="html" label="MapPartitionsRDD [21581] toJavaRDD at <unknown>:0"]; } } 21568->21569; 21569->21570; 21570->21571; 21571->21572; 21572->21573; 21573->21574; 21574->21575; 21575->21576; 21576->21577; 21577->21578; 21578->21579; 21579->21580; 21580->21581; 21581->21582; }

Event Timeline

Enable zooming