processing-stream-kafka-raw-to-minio - Details for Stage 80 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 4
Input Size / Records: 0.0 B / 464
Associated Job Ids: 80

digraph G { subgraph clusterstage_80 { label="Stage 80"; 844 [labelType="html" label="SQLExecutionRDD [844] run at <unknown>:0"]; 852 [labelType="html" label="SQLExecutionRDD [852] toJavaRDD at <unknown>:0"]; 854 [labelType="html" label="PythonRDD [854] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster1885 { label="MicroBatchScan"; 840 [labelType="html" label="DataSourceRDD [840] run at <unknown>:0"]; 841 [labelType="html" label="MapPartitionsRDD [841] run at <unknown>:0"]; } subgraph cluster1884 { label="Project"; 842 [labelType="html" label="MapPartitionsRDD [842] run at <unknown>:0"]; } subgraph cluster1880 { label="WholeStageCodegen (1)"; 843 [labelType="html" label="MapPartitionsRDD [843] run at <unknown>:0"]; } subgraph cluster1894 { label="WholeStageCodegen (1)"; 845 [labelType="html" label="MapPartitionsRDD [845] toJavaRDD at <unknown>:0"]; } subgraph cluster1893 { label="Filter"; 846 [labelType="html" label="MapPartitionsRDD [846] toJavaRDD at <unknown>:0"]; } subgraph cluster1892 { label="Project"; 847 [labelType="html" label="MapPartitionsRDD [847] toJavaRDD at <unknown>:0"]; } subgraph cluster1889 { label="WholeStageCodegen (2)"; 848 [labelType="html" label="MapPartitionsRDD [848] toJavaRDD at <unknown>:0"]; } subgraph cluster1888 { label="Project"; 849 [labelType="html" label="MapPartitionsRDD [849] toJavaRDD at <unknown>:0"]; } subgraph cluster1887 { label="DeserializeToObject"; 850 [labelType="html" label="MapPartitionsRDD [850] toJavaRDD at <unknown>:0"]; } subgraph cluster1886 { label="MapPartitions"; 851 [labelType="html" label="MapPartitionsRDD [851] toJavaRDD at <unknown>:0"]; } subgraph cluster1896 { label="mapPartitions"; 853 [labelType="html" label="MapPartitionsRDD [853] toJavaRDD at <unknown>:0"]; } } 840->841; 841->842; 842->843; 843->844; 844->845; 845->846; 846->847; 847->848; 848->849; 849->850; 850->851; 851->852; 852->853; 853->854; }

Event Timeline

Enable zooming