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

digraph G { subgraph clusterstage_1795 { label="Stage 1795"; 18847 [labelType="html" label="SQLExecutionRDD [18847] run at <unknown>:0"]; 18855 [labelType="html" label="SQLExecutionRDD [18855] toJavaRDD at <unknown>:0"]; 18857 [labelType="html" label="PythonRDD [18857] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster42172 { label="MicroBatchScan"; 18843 [labelType="html" label="DataSourceRDD [18843] run at <unknown>:0"]; 18844 [labelType="html" label="MapPartitionsRDD [18844] run at <unknown>:0"]; } subgraph cluster42171 { label="Project"; 18845 [labelType="html" label="MapPartitionsRDD [18845] run at <unknown>:0"]; } subgraph cluster42165 { label="WholeStageCodegen (1)"; 18846 [labelType="html" label="MapPartitionsRDD [18846] run at <unknown>:0"]; } subgraph cluster42181 { label="WholeStageCodegen (1)"; 18848 [labelType="html" label="MapPartitionsRDD [18848] toJavaRDD at <unknown>:0"]; } subgraph cluster42180 { label="Filter"; 18849 [labelType="html" label="MapPartitionsRDD [18849] toJavaRDD at <unknown>:0"]; } subgraph cluster42179 { label="Project"; 18850 [labelType="html" label="MapPartitionsRDD [18850] toJavaRDD at <unknown>:0"]; } subgraph cluster42176 { label="WholeStageCodegen (2)"; 18851 [labelType="html" label="MapPartitionsRDD [18851] toJavaRDD at <unknown>:0"]; } subgraph cluster42175 { label="Project"; 18852 [labelType="html" label="MapPartitionsRDD [18852] toJavaRDD at <unknown>:0"]; } subgraph cluster42174 { label="DeserializeToObject"; 18853 [labelType="html" label="MapPartitionsRDD [18853] toJavaRDD at <unknown>:0"]; } subgraph cluster42173 { label="MapPartitions"; 18854 [labelType="html" label="MapPartitionsRDD [18854] toJavaRDD at <unknown>:0"]; } subgraph cluster42183 { label="mapPartitions"; 18856 [labelType="html" label="MapPartitionsRDD [18856] toJavaRDD at <unknown>:0"]; } } 18843->18844; 18844->18845; 18845->18846; 18846->18847; 18847->18848; 18848->18849; 18849->18850; 18850->18851; 18851->18852; 18852->18853; 18853->18854; 18854->18855; 18855->18856; 18856->18857; }

Event Timeline

Enable zooming