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

digraph G { subgraph clusterstage_2015 { label="Stage 2015"; 21173 [labelType="html" label="SQLExecutionRDD [21173] run at <unknown>:0"]; 21181 [labelType="html" label="SQLExecutionRDD [21181] toJavaRDD at <unknown>:0"]; 21183 [labelType="html" label="PythonRDD [21183] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster47377 { label="MicroBatchScan"; 21169 [labelType="html" label="DataSourceRDD [21169] run at <unknown>:0"]; 21170 [labelType="html" label="MapPartitionsRDD [21170] run at <unknown>:0"]; } subgraph cluster47376 { label="Project"; 21171 [labelType="html" label="MapPartitionsRDD [21171] run at <unknown>:0"]; } subgraph cluster47372 { label="WholeStageCodegen (1)"; 21172 [labelType="html" label="MapPartitionsRDD [21172] run at <unknown>:0"]; } subgraph cluster47386 { label="WholeStageCodegen (1)"; 21174 [labelType="html" label="MapPartitionsRDD [21174] toJavaRDD at <unknown>:0"]; } subgraph cluster47385 { label="Filter"; 21175 [labelType="html" label="MapPartitionsRDD [21175] toJavaRDD at <unknown>:0"]; } subgraph cluster47384 { label="Project"; 21176 [labelType="html" label="MapPartitionsRDD [21176] toJavaRDD at <unknown>:0"]; } subgraph cluster47381 { label="WholeStageCodegen (2)"; 21177 [labelType="html" label="MapPartitionsRDD [21177] toJavaRDD at <unknown>:0"]; } subgraph cluster47380 { label="Project"; 21178 [labelType="html" label="MapPartitionsRDD [21178] toJavaRDD at <unknown>:0"]; } subgraph cluster47379 { label="DeserializeToObject"; 21179 [labelType="html" label="MapPartitionsRDD [21179] toJavaRDD at <unknown>:0"]; } subgraph cluster47378 { label="MapPartitions"; 21180 [labelType="html" label="MapPartitionsRDD [21180] toJavaRDD at <unknown>:0"]; } subgraph cluster47388 { label="mapPartitions"; 21182 [labelType="html" label="MapPartitionsRDD [21182] toJavaRDD at <unknown>:0"]; } } 21169->21170; 21170->21171; 21171->21172; 21172->21173; 21173->21174; 21174->21175; 21175->21176; 21176->21177; 21177->21178; 21178->21179; 21179->21180; 21180->21181; 21181->21182; 21182->21183; }

Event Timeline

Enable zooming