processing-stream-kafka-raw-to-minio - Details for Stage 493 (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: 493

digraph G { subgraph clusterstage_493 { label="Stage 493"; 5170 [labelType="html" label="SQLExecutionRDD [5170] run at <unknown>:0"]; 5184 [labelType="html" label="SQLExecutionRDD [5184] toJavaRDD at <unknown>:0"]; 5186 [labelType="html" label="PythonRDD [5186] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster11567 { label="MicroBatchScan"; 5166 [labelType="html" label="DataSourceRDD [5166] run at <unknown>:0"]; 5167 [labelType="html" label="MapPartitionsRDD [5167] run at <unknown>:0"]; } subgraph cluster11566 { label="Project"; 5168 [labelType="html" label="MapPartitionsRDD [5168] run at <unknown>:0"]; } subgraph cluster11562 { label="WholeStageCodegen (1)"; 5169 [labelType="html" label="MapPartitionsRDD [5169] run at <unknown>:0"]; } subgraph cluster11582 { label="WholeStageCodegen (1)"; 5172 [labelType="html" label="MapPartitionsRDD [5172] toJavaRDD at <unknown>:0"]; } subgraph cluster11581 { label="Filter"; 5173 [labelType="html" label="MapPartitionsRDD [5173] toJavaRDD at <unknown>:0"]; } subgraph cluster11580 { label="Project"; 5174 [labelType="html" label="MapPartitionsRDD [5174] toJavaRDD at <unknown>:0"]; } subgraph cluster11571 { label="WholeStageCodegen (2)"; 5177 [labelType="html" label="MapPartitionsRDD [5177] toJavaRDD at <unknown>:0"]; } subgraph cluster11570 { label="Project"; 5178 [labelType="html" label="MapPartitionsRDD [5178] toJavaRDD at <unknown>:0"]; } subgraph cluster11569 { label="DeserializeToObject"; 5182 [labelType="html" label="MapPartitionsRDD [5182] toJavaRDD at <unknown>:0"]; } subgraph cluster11568 { label="MapPartitions"; 5183 [labelType="html" label="MapPartitionsRDD [5183] toJavaRDD at <unknown>:0"]; } subgraph cluster11586 { label="mapPartitions"; 5185 [labelType="html" label="MapPartitionsRDD [5185] toJavaRDD at <unknown>:0"]; } } 5166->5167; 5167->5168; 5168->5169; 5169->5170; 5170->5172; 5172->5173; 5173->5174; 5174->5177; 5177->5178; 5178->5182; 5182->5183; 5183->5184; 5184->5185; 5185->5186; }

Event Timeline

Enable zooming