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

digraph G { subgraph clusterstage_1847 { label="Stage 1847"; 19393 [labelType="html" label="SQLExecutionRDD [19393] run at <unknown>:0"]; 19401 [labelType="html" label="SQLExecutionRDD [19401] toJavaRDD at <unknown>:0"]; 19403 [labelType="html" label="PythonRDD [19403] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster43394 { label="MicroBatchScan"; 19389 [labelType="html" label="DataSourceRDD [19389] run at <unknown>:0"]; 19390 [labelType="html" label="MapPartitionsRDD [19390] run at <unknown>:0"]; } subgraph cluster43393 { label="Project"; 19391 [labelType="html" label="MapPartitionsRDD [19391] run at <unknown>:0"]; } subgraph cluster43389 { label="WholeStageCodegen (1)"; 19392 [labelType="html" label="MapPartitionsRDD [19392] run at <unknown>:0"]; } subgraph cluster43403 { label="WholeStageCodegen (1)"; 19394 [labelType="html" label="MapPartitionsRDD [19394] toJavaRDD at <unknown>:0"]; } subgraph cluster43402 { label="Filter"; 19395 [labelType="html" label="MapPartitionsRDD [19395] toJavaRDD at <unknown>:0"]; } subgraph cluster43401 { label="Project"; 19396 [labelType="html" label="MapPartitionsRDD [19396] toJavaRDD at <unknown>:0"]; } subgraph cluster43398 { label="WholeStageCodegen (2)"; 19397 [labelType="html" label="MapPartitionsRDD [19397] toJavaRDD at <unknown>:0"]; } subgraph cluster43397 { label="Project"; 19398 [labelType="html" label="MapPartitionsRDD [19398] toJavaRDD at <unknown>:0"]; } subgraph cluster43396 { label="DeserializeToObject"; 19399 [labelType="html" label="MapPartitionsRDD [19399] toJavaRDD at <unknown>:0"]; } subgraph cluster43395 { label="MapPartitions"; 19400 [labelType="html" label="MapPartitionsRDD [19400] toJavaRDD at <unknown>:0"]; } subgraph cluster43405 { label="mapPartitions"; 19402 [labelType="html" label="MapPartitionsRDD [19402] toJavaRDD at <unknown>:0"]; } } 19389->19390; 19390->19391; 19391->19392; 19392->19393; 19393->19394; 19394->19395; 19395->19396; 19396->19397; 19397->19398; 19398->19399; 19399->19400; 19400->19401; 19401->19402; 19402->19403; }

Event Timeline

Enable zooming