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

digraph G { subgraph clusterstage_490 { label="Stage 490"; 5149 [labelType="html" label="SQLExecutionRDD [5149] run at <unknown>:0"]; 5157 [labelType="html" label="SQLExecutionRDD [5157] toJavaRDD at <unknown>:0"]; 5159 [labelType="html" label="PythonRDD [5159] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster11520 { label="MicroBatchScan"; 5145 [labelType="html" label="DataSourceRDD [5145] run at <unknown>:0"]; 5146 [labelType="html" label="MapPartitionsRDD [5146] run at <unknown>:0"]; } subgraph cluster11519 { label="Project"; 5147 [labelType="html" label="MapPartitionsRDD [5147] run at <unknown>:0"]; } subgraph cluster11515 { label="WholeStageCodegen (1)"; 5148 [labelType="html" label="MapPartitionsRDD [5148] run at <unknown>:0"]; } subgraph cluster11529 { label="WholeStageCodegen (1)"; 5150 [labelType="html" label="MapPartitionsRDD [5150] toJavaRDD at <unknown>:0"]; } subgraph cluster11528 { label="Filter"; 5151 [labelType="html" label="MapPartitionsRDD [5151] toJavaRDD at <unknown>:0"]; } subgraph cluster11527 { label="Project"; 5152 [labelType="html" label="MapPartitionsRDD [5152] toJavaRDD at <unknown>:0"]; } subgraph cluster11524 { label="WholeStageCodegen (2)"; 5153 [labelType="html" label="MapPartitionsRDD [5153] toJavaRDD at <unknown>:0"]; } subgraph cluster11523 { label="Project"; 5154 [labelType="html" label="MapPartitionsRDD [5154] toJavaRDD at <unknown>:0"]; } subgraph cluster11522 { label="DeserializeToObject"; 5155 [labelType="html" label="MapPartitionsRDD [5155] toJavaRDD at <unknown>:0"]; } subgraph cluster11521 { label="MapPartitions"; 5156 [labelType="html" label="MapPartitionsRDD [5156] toJavaRDD at <unknown>:0"]; } subgraph cluster11531 { label="mapPartitions"; 5158 [labelType="html" label="MapPartitionsRDD [5158] toJavaRDD at <unknown>:0"]; } } 5145->5146; 5146->5147; 5147->5148; 5148->5149; 5149->5150; 5150->5151; 5151->5152; 5152->5153; 5153->5154; 5154->5155; 5155->5156; 5156->5157; 5157->5158; 5158->5159; }

Event Timeline

Enable zooming