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

digraph G { subgraph clusterstage_1026 { label="Stage 1026"; 10778 [labelType="html" label="SQLExecutionRDD [10778] run at <unknown>:0"]; 10792 [labelType="html" label="SQLExecutionRDD [10792] toJavaRDD at <unknown>:0"]; 10794 [labelType="html" label="PythonRDD [10794] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster24112 { label="MicroBatchScan"; 10774 [labelType="html" label="DataSourceRDD [10774] run at <unknown>:0"]; 10775 [labelType="html" label="MapPartitionsRDD [10775] run at <unknown>:0"]; } subgraph cluster24111 { label="Project"; 10776 [labelType="html" label="MapPartitionsRDD [10776] run at <unknown>:0"]; } subgraph cluster24107 { label="WholeStageCodegen (1)"; 10777 [labelType="html" label="MapPartitionsRDD [10777] run at <unknown>:0"]; } subgraph cluster24129 { label="WholeStageCodegen (1)"; 10785 [labelType="html" label="MapPartitionsRDD [10785] toJavaRDD at <unknown>:0"]; } subgraph cluster24128 { label="Filter"; 10786 [labelType="html" label="MapPartitionsRDD [10786] toJavaRDD at <unknown>:0"]; } subgraph cluster24127 { label="Project"; 10787 [labelType="html" label="MapPartitionsRDD [10787] toJavaRDD at <unknown>:0"]; } subgraph cluster24124 { label="WholeStageCodegen (2)"; 10788 [labelType="html" label="MapPartitionsRDD [10788] toJavaRDD at <unknown>:0"]; } subgraph cluster24123 { label="Project"; 10789 [labelType="html" label="MapPartitionsRDD [10789] toJavaRDD at <unknown>:0"]; } subgraph cluster24122 { label="DeserializeToObject"; 10790 [labelType="html" label="MapPartitionsRDD [10790] toJavaRDD at <unknown>:0"]; } subgraph cluster24121 { label="MapPartitions"; 10791 [labelType="html" label="MapPartitionsRDD [10791] toJavaRDD at <unknown>:0"]; } subgraph cluster24131 { label="mapPartitions"; 10793 [labelType="html" label="MapPartitionsRDD [10793] toJavaRDD at <unknown>:0"]; } } 10774->10775; 10775->10776; 10776->10777; 10777->10778; 10778->10785; 10785->10786; 10786->10787; 10787->10788; 10788->10789; 10789->10790; 10790->10791; 10791->10792; 10792->10793; 10793->10794; }

Event Timeline

Enable zooming