processing-stream-kafka-raw-to-minio - Details for Stage 1695 (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 / 476
Associated Job Ids: 1696

digraph G { subgraph clusterstage_1695 { label="Stage 1695"; 17813 [labelType="html" label="SQLExecutionRDD [17813] run at <unknown>:0"]; 17821 [labelType="html" label="SQLExecutionRDD [17821] toJavaRDD at <unknown>:0"]; 17823 [labelType="html" label="PythonRDD [17823] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster39857 { label="MicroBatchScan"; 17809 [labelType="html" label="DataSourceRDD [17809] run at <unknown>:0"]; 17810 [labelType="html" label="MapPartitionsRDD [17810] run at <unknown>:0"]; } subgraph cluster39856 { label="Project"; 17811 [labelType="html" label="MapPartitionsRDD [17811] run at <unknown>:0"]; } subgraph cluster39852 { label="WholeStageCodegen (1)"; 17812 [labelType="html" label="MapPartitionsRDD [17812] run at <unknown>:0"]; } subgraph cluster39866 { label="WholeStageCodegen (1)"; 17814 [labelType="html" label="MapPartitionsRDD [17814] toJavaRDD at <unknown>:0"]; } subgraph cluster39865 { label="Filter"; 17815 [labelType="html" label="MapPartitionsRDD [17815] toJavaRDD at <unknown>:0"]; } subgraph cluster39864 { label="Project"; 17816 [labelType="html" label="MapPartitionsRDD [17816] toJavaRDD at <unknown>:0"]; } subgraph cluster39861 { label="WholeStageCodegen (2)"; 17817 [labelType="html" label="MapPartitionsRDD [17817] toJavaRDD at <unknown>:0"]; } subgraph cluster39860 { label="Project"; 17818 [labelType="html" label="MapPartitionsRDD [17818] toJavaRDD at <unknown>:0"]; } subgraph cluster39859 { label="DeserializeToObject"; 17819 [labelType="html" label="MapPartitionsRDD [17819] toJavaRDD at <unknown>:0"]; } subgraph cluster39858 { label="MapPartitions"; 17820 [labelType="html" label="MapPartitionsRDD [17820] toJavaRDD at <unknown>:0"]; } subgraph cluster39868 { label="mapPartitions"; 17822 [labelType="html" label="MapPartitionsRDD [17822] toJavaRDD at <unknown>:0"]; } } 17809->17810; 17810->17811; 17811->17812; 17812->17813; 17813->17814; 17814->17815; 17815->17816; 17816->17817; 17817->17818; 17818->17819; 17819->17820; 17820->17821; 17821->17822; 17822->17823; }

Event Timeline

Enable zooming