processing-stream-kafka-raw-to-minio - Details for Stage 1986 (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 / 451
Associated Job Ids: 1987

digraph G { subgraph clusterstage_1986 { label="Stage 1986"; 20864 [labelType="html" label="SQLExecutionRDD [20864] run at <unknown>:0"]; 20872 [labelType="html" label="SQLExecutionRDD [20872] toJavaRDD at <unknown>:0"]; 20874 [labelType="html" label="PythonRDD [20874] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster46680 { label="MicroBatchScan"; 20860 [labelType="html" label="DataSourceRDD [20860] run at <unknown>:0"]; 20861 [labelType="html" label="MapPartitionsRDD [20861] run at <unknown>:0"]; } subgraph cluster46679 { label="Project"; 20862 [labelType="html" label="MapPartitionsRDD [20862] run at <unknown>:0"]; } subgraph cluster46675 { label="WholeStageCodegen (1)"; 20863 [labelType="html" label="MapPartitionsRDD [20863] run at <unknown>:0"]; } subgraph cluster46689 { label="WholeStageCodegen (1)"; 20865 [labelType="html" label="MapPartitionsRDD [20865] toJavaRDD at <unknown>:0"]; } subgraph cluster46688 { label="Filter"; 20866 [labelType="html" label="MapPartitionsRDD [20866] toJavaRDD at <unknown>:0"]; } subgraph cluster46687 { label="Project"; 20867 [labelType="html" label="MapPartitionsRDD [20867] toJavaRDD at <unknown>:0"]; } subgraph cluster46684 { label="WholeStageCodegen (2)"; 20868 [labelType="html" label="MapPartitionsRDD [20868] toJavaRDD at <unknown>:0"]; } subgraph cluster46683 { label="Project"; 20869 [labelType="html" label="MapPartitionsRDD [20869] toJavaRDD at <unknown>:0"]; } subgraph cluster46682 { label="DeserializeToObject"; 20870 [labelType="html" label="MapPartitionsRDD [20870] toJavaRDD at <unknown>:0"]; } subgraph cluster46681 { label="MapPartitions"; 20871 [labelType="html" label="MapPartitionsRDD [20871] toJavaRDD at <unknown>:0"]; } subgraph cluster46691 { label="mapPartitions"; 20873 [labelType="html" label="MapPartitionsRDD [20873] toJavaRDD at <unknown>:0"]; } } 20860->20861; 20861->20862; 20862->20863; 20863->20864; 20864->20865; 20865->20866; 20866->20867; 20867->20868; 20868->20869; 20869->20870; 20870->20871; 20871->20872; 20872->20873; 20873->20874; }

Event Timeline

Enable zooming