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

digraph G { subgraph clusterstage_816 { label="Stage 816"; 8572 [labelType="html" label="SQLExecutionRDD [8572] run at <unknown>:0"]; 8580 [labelType="html" label="SQLExecutionRDD [8580] toJavaRDD at <unknown>:0"]; 8582 [labelType="html" label="PythonRDD [8582] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster19181 { label="MicroBatchScan"; 8568 [labelType="html" label="DataSourceRDD [8568] run at <unknown>:0"]; 8569 [labelType="html" label="MapPartitionsRDD [8569] run at <unknown>:0"]; } subgraph cluster19180 { label="Project"; 8570 [labelType="html" label="MapPartitionsRDD [8570] run at <unknown>:0"]; } subgraph cluster19176 { label="WholeStageCodegen (1)"; 8571 [labelType="html" label="MapPartitionsRDD [8571] run at <unknown>:0"]; } subgraph cluster19190 { label="WholeStageCodegen (1)"; 8573 [labelType="html" label="MapPartitionsRDD [8573] toJavaRDD at <unknown>:0"]; } subgraph cluster19189 { label="Filter"; 8574 [labelType="html" label="MapPartitionsRDD [8574] toJavaRDD at <unknown>:0"]; } subgraph cluster19188 { label="Project"; 8575 [labelType="html" label="MapPartitionsRDD [8575] toJavaRDD at <unknown>:0"]; } subgraph cluster19185 { label="WholeStageCodegen (2)"; 8576 [labelType="html" label="MapPartitionsRDD [8576] toJavaRDD at <unknown>:0"]; } subgraph cluster19184 { label="Project"; 8577 [labelType="html" label="MapPartitionsRDD [8577] toJavaRDD at <unknown>:0"]; } subgraph cluster19183 { label="DeserializeToObject"; 8578 [labelType="html" label="MapPartitionsRDD [8578] toJavaRDD at <unknown>:0"]; } subgraph cluster19182 { label="MapPartitions"; 8579 [labelType="html" label="MapPartitionsRDD [8579] toJavaRDD at <unknown>:0"]; } subgraph cluster19192 { label="mapPartitions"; 8581 [labelType="html" label="MapPartitionsRDD [8581] toJavaRDD at <unknown>:0"]; } } 8568->8569; 8569->8570; 8570->8571; 8571->8572; 8572->8573; 8573->8574; 8574->8575; 8575->8576; 8576->8577; 8577->8578; 8578->8579; 8579->8580; 8580->8581; 8581->8582; }

Event Timeline

Enable zooming