processing-stream-kafka-raw-to-minio - Details for Stage 1031 (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 / 463
Associated Job Ids: 1032

digraph G { subgraph clusterstage_1031 { label="Stage 1031"; 10841 [labelType="html" label="SQLExecutionRDD [10841] run at <unknown>:0"]; 10849 [labelType="html" label="SQLExecutionRDD [10849] toJavaRDD at <unknown>:0"]; 10851 [labelType="html" label="PythonRDD [10851] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster24253 { label="MicroBatchScan"; 10837 [labelType="html" label="DataSourceRDD [10837] run at <unknown>:0"]; 10838 [labelType="html" label="MapPartitionsRDD [10838] run at <unknown>:0"]; } subgraph cluster24252 { label="Project"; 10839 [labelType="html" label="MapPartitionsRDD [10839] run at <unknown>:0"]; } subgraph cluster24248 { label="WholeStageCodegen (1)"; 10840 [labelType="html" label="MapPartitionsRDD [10840] run at <unknown>:0"]; } subgraph cluster24262 { label="WholeStageCodegen (1)"; 10842 [labelType="html" label="MapPartitionsRDD [10842] toJavaRDD at <unknown>:0"]; } subgraph cluster24261 { label="Filter"; 10843 [labelType="html" label="MapPartitionsRDD [10843] toJavaRDD at <unknown>:0"]; } subgraph cluster24260 { label="Project"; 10844 [labelType="html" label="MapPartitionsRDD [10844] toJavaRDD at <unknown>:0"]; } subgraph cluster24257 { label="WholeStageCodegen (2)"; 10845 [labelType="html" label="MapPartitionsRDD [10845] toJavaRDD at <unknown>:0"]; } subgraph cluster24256 { label="Project"; 10846 [labelType="html" label="MapPartitionsRDD [10846] toJavaRDD at <unknown>:0"]; } subgraph cluster24255 { label="DeserializeToObject"; 10847 [labelType="html" label="MapPartitionsRDD [10847] toJavaRDD at <unknown>:0"]; } subgraph cluster24254 { label="MapPartitions"; 10848 [labelType="html" label="MapPartitionsRDD [10848] toJavaRDD at <unknown>:0"]; } subgraph cluster24264 { label="mapPartitions"; 10850 [labelType="html" label="MapPartitionsRDD [10850] toJavaRDD at <unknown>:0"]; } } 10837->10838; 10838->10839; 10839->10840; 10840->10841; 10841->10842; 10842->10843; 10843->10844; 10844->10845; 10845->10846; 10846->10847; 10847->10848; 10848->10849; 10849->10850; 10850->10851; }

Event Timeline

Enable zooming