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

digraph G { subgraph clusterstage_1751 { label="Stage 1751"; 18379 [labelType="html" label="SQLExecutionRDD [18379] run at <unknown>:0"]; 18393 [labelType="html" label="SQLExecutionRDD [18393] toJavaRDD at <unknown>:0"]; 18395 [labelType="html" label="PythonRDD [18395] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster41130 { label="MicroBatchScan"; 18375 [labelType="html" label="DataSourceRDD [18375] run at <unknown>:0"]; 18376 [labelType="html" label="MapPartitionsRDD [18376] run at <unknown>:0"]; } subgraph cluster41129 { label="Project"; 18377 [labelType="html" label="MapPartitionsRDD [18377] run at <unknown>:0"]; } subgraph cluster41125 { label="WholeStageCodegen (1)"; 18378 [labelType="html" label="MapPartitionsRDD [18378] run at <unknown>:0"]; } subgraph cluster41147 { label="WholeStageCodegen (1)"; 18386 [labelType="html" label="MapPartitionsRDD [18386] toJavaRDD at <unknown>:0"]; } subgraph cluster41146 { label="Filter"; 18387 [labelType="html" label="MapPartitionsRDD [18387] toJavaRDD at <unknown>:0"]; } subgraph cluster41145 { label="Project"; 18388 [labelType="html" label="MapPartitionsRDD [18388] toJavaRDD at <unknown>:0"]; } subgraph cluster41142 { label="WholeStageCodegen (2)"; 18389 [labelType="html" label="MapPartitionsRDD [18389] toJavaRDD at <unknown>:0"]; } subgraph cluster41141 { label="Project"; 18390 [labelType="html" label="MapPartitionsRDD [18390] toJavaRDD at <unknown>:0"]; } subgraph cluster41140 { label="DeserializeToObject"; 18391 [labelType="html" label="MapPartitionsRDD [18391] toJavaRDD at <unknown>:0"]; } subgraph cluster41139 { label="MapPartitions"; 18392 [labelType="html" label="MapPartitionsRDD [18392] toJavaRDD at <unknown>:0"]; } subgraph cluster41149 { label="mapPartitions"; 18394 [labelType="html" label="MapPartitionsRDD [18394] toJavaRDD at <unknown>:0"]; } } 18375->18376; 18376->18377; 18377->18378; 18378->18379; 18379->18386; 18386->18387; 18387->18388; 18388->18389; 18389->18390; 18390->18391; 18391->18392; 18392->18393; 18393->18394; 18394->18395; }

Event Timeline

Enable zooming