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

digraph G { subgraph clusterstage_990 { label="Stage 990"; 10399 [labelType="html" label="SQLExecutionRDD [10399] run at <unknown>:0"]; 10407 [labelType="html" label="SQLExecutionRDD [10407] toJavaRDD at <unknown>:0"]; 10409 [labelType="html" label="PythonRDD [10409] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster23270 { label="MicroBatchScan"; 10395 [labelType="html" label="DataSourceRDD [10395] run at <unknown>:0"]; 10396 [labelType="html" label="MapPartitionsRDD [10396] run at <unknown>:0"]; } subgraph cluster23269 { label="Project"; 10397 [labelType="html" label="MapPartitionsRDD [10397] run at <unknown>:0"]; } subgraph cluster23265 { label="WholeStageCodegen (1)"; 10398 [labelType="html" label="MapPartitionsRDD [10398] run at <unknown>:0"]; } subgraph cluster23279 { label="WholeStageCodegen (1)"; 10400 [labelType="html" label="MapPartitionsRDD [10400] toJavaRDD at <unknown>:0"]; } subgraph cluster23278 { label="Filter"; 10401 [labelType="html" label="MapPartitionsRDD [10401] toJavaRDD at <unknown>:0"]; } subgraph cluster23277 { label="Project"; 10402 [labelType="html" label="MapPartitionsRDD [10402] toJavaRDD at <unknown>:0"]; } subgraph cluster23274 { label="WholeStageCodegen (2)"; 10403 [labelType="html" label="MapPartitionsRDD [10403] toJavaRDD at <unknown>:0"]; } subgraph cluster23273 { label="Project"; 10404 [labelType="html" label="MapPartitionsRDD [10404] toJavaRDD at <unknown>:0"]; } subgraph cluster23272 { label="DeserializeToObject"; 10405 [labelType="html" label="MapPartitionsRDD [10405] toJavaRDD at <unknown>:0"]; } subgraph cluster23271 { label="MapPartitions"; 10406 [labelType="html" label="MapPartitionsRDD [10406] toJavaRDD at <unknown>:0"]; } subgraph cluster23281 { label="mapPartitions"; 10408 [labelType="html" label="MapPartitionsRDD [10408] toJavaRDD at <unknown>:0"]; } } 10395->10396; 10396->10397; 10397->10398; 10398->10399; 10399->10400; 10400->10401; 10401->10402; 10402->10403; 10403->10404; 10404->10405; 10405->10406; 10406->10407; 10407->10408; 10408->10409; }

Event Timeline

Enable zooming