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

digraph G { subgraph clusterstage_2005 { label="Stage 2005"; 21068 [labelType="html" label="SQLExecutionRDD [21068] run at <unknown>:0"]; 21076 [labelType="html" label="SQLExecutionRDD [21076] toJavaRDD at <unknown>:0"]; 21078 [labelType="html" label="PythonRDD [21078] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster47142 { label="MicroBatchScan"; 21064 [labelType="html" label="DataSourceRDD [21064] run at <unknown>:0"]; 21065 [labelType="html" label="MapPartitionsRDD [21065] run at <unknown>:0"]; } subgraph cluster47141 { label="Project"; 21066 [labelType="html" label="MapPartitionsRDD [21066] run at <unknown>:0"]; } subgraph cluster47137 { label="WholeStageCodegen (1)"; 21067 [labelType="html" label="MapPartitionsRDD [21067] run at <unknown>:0"]; } subgraph cluster47151 { label="WholeStageCodegen (1)"; 21069 [labelType="html" label="MapPartitionsRDD [21069] toJavaRDD at <unknown>:0"]; } subgraph cluster47150 { label="Filter"; 21070 [labelType="html" label="MapPartitionsRDD [21070] toJavaRDD at <unknown>:0"]; } subgraph cluster47149 { label="Project"; 21071 [labelType="html" label="MapPartitionsRDD [21071] toJavaRDD at <unknown>:0"]; } subgraph cluster47146 { label="WholeStageCodegen (2)"; 21072 [labelType="html" label="MapPartitionsRDD [21072] toJavaRDD at <unknown>:0"]; } subgraph cluster47145 { label="Project"; 21073 [labelType="html" label="MapPartitionsRDD [21073] toJavaRDD at <unknown>:0"]; } subgraph cluster47144 { label="DeserializeToObject"; 21074 [labelType="html" label="MapPartitionsRDD [21074] toJavaRDD at <unknown>:0"]; } subgraph cluster47143 { label="MapPartitions"; 21075 [labelType="html" label="MapPartitionsRDD [21075] toJavaRDD at <unknown>:0"]; } subgraph cluster47153 { label="mapPartitions"; 21077 [labelType="html" label="MapPartitionsRDD [21077] toJavaRDD at <unknown>:0"]; } } 21064->21065; 21065->21066; 21066->21067; 21067->21068; 21068->21069; 21069->21070; 21070->21071; 21071->21072; 21072->21073; 21073->21074; 21074->21075; 21075->21076; 21076->21077; 21077->21078; }

Event Timeline

Enable zooming