processing-stream-kafka-raw-to-minio - Details for Stage 1221 (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 / 481
Associated Job Ids: 1222

digraph G { subgraph clusterstage_1221 { label="Stage 1221"; 12836 [labelType="html" label="SQLExecutionRDD [12836] run at <unknown>:0"]; 12844 [labelType="html" label="SQLExecutionRDD [12844] toJavaRDD at <unknown>:0"]; 12846 [labelType="html" label="PythonRDD [12846] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster28718 { label="MicroBatchScan"; 12832 [labelType="html" label="DataSourceRDD [12832] run at <unknown>:0"]; 12833 [labelType="html" label="MapPartitionsRDD [12833] run at <unknown>:0"]; } subgraph cluster28717 { label="Project"; 12834 [labelType="html" label="MapPartitionsRDD [12834] run at <unknown>:0"]; } subgraph cluster28713 { label="WholeStageCodegen (1)"; 12835 [labelType="html" label="MapPartitionsRDD [12835] run at <unknown>:0"]; } subgraph cluster28727 { label="WholeStageCodegen (1)"; 12837 [labelType="html" label="MapPartitionsRDD [12837] toJavaRDD at <unknown>:0"]; } subgraph cluster28726 { label="Filter"; 12838 [labelType="html" label="MapPartitionsRDD [12838] toJavaRDD at <unknown>:0"]; } subgraph cluster28725 { label="Project"; 12839 [labelType="html" label="MapPartitionsRDD [12839] toJavaRDD at <unknown>:0"]; } subgraph cluster28722 { label="WholeStageCodegen (2)"; 12840 [labelType="html" label="MapPartitionsRDD [12840] toJavaRDD at <unknown>:0"]; } subgraph cluster28721 { label="Project"; 12841 [labelType="html" label="MapPartitionsRDD [12841] toJavaRDD at <unknown>:0"]; } subgraph cluster28720 { label="DeserializeToObject"; 12842 [labelType="html" label="MapPartitionsRDD [12842] toJavaRDD at <unknown>:0"]; } subgraph cluster28719 { label="MapPartitions"; 12843 [labelType="html" label="MapPartitionsRDD [12843] toJavaRDD at <unknown>:0"]; } subgraph cluster28729 { label="mapPartitions"; 12845 [labelType="html" label="MapPartitionsRDD [12845] toJavaRDD at <unknown>:0"]; } } 12832->12833; 12833->12834; 12834->12835; 12835->12836; 12836->12837; 12837->12838; 12838->12839; 12839->12840; 12840->12841; 12841->12842; 12842->12843; 12843->12844; 12844->12845; 12845->12846; }

Event Timeline

Enable zooming