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

digraph G { subgraph clusterstage_418 { label="Stage 418"; 4393 [labelType="html" label="SQLExecutionRDD [4393] run at <unknown>:0"]; 4401 [labelType="html" label="SQLExecutionRDD [4401] toJavaRDD at <unknown>:0"]; 4403 [labelType="html" label="PythonRDD [4403] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster9828 { label="MicroBatchScan"; 4389 [labelType="html" label="DataSourceRDD [4389] run at <unknown>:0"]; 4390 [labelType="html" label="MapPartitionsRDD [4390] run at <unknown>:0"]; } subgraph cluster9827 { label="Project"; 4391 [labelType="html" label="MapPartitionsRDD [4391] run at <unknown>:0"]; } subgraph cluster9823 { label="WholeStageCodegen (1)"; 4392 [labelType="html" label="MapPartitionsRDD [4392] run at <unknown>:0"]; } subgraph cluster9837 { label="WholeStageCodegen (1)"; 4394 [labelType="html" label="MapPartitionsRDD [4394] toJavaRDD at <unknown>:0"]; } subgraph cluster9836 { label="Filter"; 4395 [labelType="html" label="MapPartitionsRDD [4395] toJavaRDD at <unknown>:0"]; } subgraph cluster9835 { label="Project"; 4396 [labelType="html" label="MapPartitionsRDD [4396] toJavaRDD at <unknown>:0"]; } subgraph cluster9832 { label="WholeStageCodegen (2)"; 4397 [labelType="html" label="MapPartitionsRDD [4397] toJavaRDD at <unknown>:0"]; } subgraph cluster9831 { label="Project"; 4398 [labelType="html" label="MapPartitionsRDD [4398] toJavaRDD at <unknown>:0"]; } subgraph cluster9830 { label="DeserializeToObject"; 4399 [labelType="html" label="MapPartitionsRDD [4399] toJavaRDD at <unknown>:0"]; } subgraph cluster9829 { label="MapPartitions"; 4400 [labelType="html" label="MapPartitionsRDD [4400] toJavaRDD at <unknown>:0"]; } subgraph cluster9839 { label="mapPartitions"; 4402 [labelType="html" label="MapPartitionsRDD [4402] toJavaRDD at <unknown>:0"]; } } 4389->4390; 4390->4391; 4391->4392; 4392->4393; 4393->4394; 4394->4395; 4395->4396; 4396->4397; 4397->4398; 4398->4399; 4399->4400; 4400->4401; 4401->4402; 4402->4403; }

Event Timeline

Enable zooming