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

digraph G { subgraph clusterstage_1951 { label="Stage 1951"; 20501 [labelType="html" label="SQLExecutionRDD [20501] run at <unknown>:0"]; 20509 [labelType="html" label="SQLExecutionRDD [20509] toJavaRDD at <unknown>:0"]; 20511 [labelType="html" label="PythonRDD [20511] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster45873 { label="MicroBatchScan"; 20497 [labelType="html" label="DataSourceRDD [20497] run at <unknown>:0"]; 20498 [labelType="html" label="MapPartitionsRDD [20498] run at <unknown>:0"]; } subgraph cluster45872 { label="Project"; 20499 [labelType="html" label="MapPartitionsRDD [20499] run at <unknown>:0"]; } subgraph cluster45868 { label="WholeStageCodegen (1)"; 20500 [labelType="html" label="MapPartitionsRDD [20500] run at <unknown>:0"]; } subgraph cluster45882 { label="WholeStageCodegen (1)"; 20502 [labelType="html" label="MapPartitionsRDD [20502] toJavaRDD at <unknown>:0"]; } subgraph cluster45881 { label="Filter"; 20503 [labelType="html" label="MapPartitionsRDD [20503] toJavaRDD at <unknown>:0"]; } subgraph cluster45880 { label="Project"; 20504 [labelType="html" label="MapPartitionsRDD [20504] toJavaRDD at <unknown>:0"]; } subgraph cluster45877 { label="WholeStageCodegen (2)"; 20505 [labelType="html" label="MapPartitionsRDD [20505] toJavaRDD at <unknown>:0"]; } subgraph cluster45876 { label="Project"; 20506 [labelType="html" label="MapPartitionsRDD [20506] toJavaRDD at <unknown>:0"]; } subgraph cluster45875 { label="DeserializeToObject"; 20507 [labelType="html" label="MapPartitionsRDD [20507] toJavaRDD at <unknown>:0"]; } subgraph cluster45874 { label="MapPartitions"; 20508 [labelType="html" label="MapPartitionsRDD [20508] toJavaRDD at <unknown>:0"]; } subgraph cluster45884 { label="mapPartitions"; 20510 [labelType="html" label="MapPartitionsRDD [20510] toJavaRDD at <unknown>:0"]; } } 20497->20498; 20498->20499; 20499->20500; 20500->20501; 20501->20502; 20502->20503; 20503->20504; 20504->20505; 20505->20506; 20506->20507; 20507->20508; 20508->20509; 20509->20510; 20510->20511; }

Event Timeline

Enable zooming