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

digraph G { subgraph clusterstage_1649 { label="Stage 1649"; 17330 [labelType="html" label="SQLExecutionRDD [17330] run at <unknown>:0"]; 17338 [labelType="html" label="SQLExecutionRDD [17338] toJavaRDD at <unknown>:0"]; 17340 [labelType="html" label="PythonRDD [17340] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster38776 { label="MicroBatchScan"; 17326 [labelType="html" label="DataSourceRDD [17326] run at <unknown>:0"]; 17327 [labelType="html" label="MapPartitionsRDD [17327] run at <unknown>:0"]; } subgraph cluster38775 { label="Project"; 17328 [labelType="html" label="MapPartitionsRDD [17328] run at <unknown>:0"]; } subgraph cluster38771 { label="WholeStageCodegen (1)"; 17329 [labelType="html" label="MapPartitionsRDD [17329] run at <unknown>:0"]; } subgraph cluster38785 { label="WholeStageCodegen (1)"; 17331 [labelType="html" label="MapPartitionsRDD [17331] toJavaRDD at <unknown>:0"]; } subgraph cluster38784 { label="Filter"; 17332 [labelType="html" label="MapPartitionsRDD [17332] toJavaRDD at <unknown>:0"]; } subgraph cluster38783 { label="Project"; 17333 [labelType="html" label="MapPartitionsRDD [17333] toJavaRDD at <unknown>:0"]; } subgraph cluster38780 { label="WholeStageCodegen (2)"; 17334 [labelType="html" label="MapPartitionsRDD [17334] toJavaRDD at <unknown>:0"]; } subgraph cluster38779 { label="Project"; 17335 [labelType="html" label="MapPartitionsRDD [17335] toJavaRDD at <unknown>:0"]; } subgraph cluster38778 { label="DeserializeToObject"; 17336 [labelType="html" label="MapPartitionsRDD [17336] toJavaRDD at <unknown>:0"]; } subgraph cluster38777 { label="MapPartitions"; 17337 [labelType="html" label="MapPartitionsRDD [17337] toJavaRDD at <unknown>:0"]; } subgraph cluster38787 { label="mapPartitions"; 17339 [labelType="html" label="MapPartitionsRDD [17339] toJavaRDD at <unknown>:0"]; } } 17326->17327; 17327->17328; 17328->17329; 17329->17330; 17330->17331; 17331->17332; 17332->17333; 17333->17334; 17334->17335; 17335->17336; 17336->17337; 17337->17338; 17338->17339; 17339->17340; }

Event Timeline

Enable zooming