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

digraph G { subgraph clusterstage_602 { label="Stage 602"; 6325 [labelType="html" label="SQLExecutionRDD [6325] run at <unknown>:0"]; 6333 [labelType="html" label="SQLExecutionRDD [6333] toJavaRDD at <unknown>:0"]; 6335 [labelType="html" label="PythonRDD [6335] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster14152 { label="MicroBatchScan"; 6321 [labelType="html" label="DataSourceRDD [6321] run at <unknown>:0"]; 6322 [labelType="html" label="MapPartitionsRDD [6322] run at <unknown>:0"]; } subgraph cluster14151 { label="Project"; 6323 [labelType="html" label="MapPartitionsRDD [6323] run at <unknown>:0"]; } subgraph cluster14147 { label="WholeStageCodegen (1)"; 6324 [labelType="html" label="MapPartitionsRDD [6324] run at <unknown>:0"]; } subgraph cluster14161 { label="WholeStageCodegen (1)"; 6326 [labelType="html" label="MapPartitionsRDD [6326] toJavaRDD at <unknown>:0"]; } subgraph cluster14160 { label="Filter"; 6327 [labelType="html" label="MapPartitionsRDD [6327] toJavaRDD at <unknown>:0"]; } subgraph cluster14159 { label="Project"; 6328 [labelType="html" label="MapPartitionsRDD [6328] toJavaRDD at <unknown>:0"]; } subgraph cluster14156 { label="WholeStageCodegen (2)"; 6329 [labelType="html" label="MapPartitionsRDD [6329] toJavaRDD at <unknown>:0"]; } subgraph cluster14155 { label="Project"; 6330 [labelType="html" label="MapPartitionsRDD [6330] toJavaRDD at <unknown>:0"]; } subgraph cluster14154 { label="DeserializeToObject"; 6331 [labelType="html" label="MapPartitionsRDD [6331] toJavaRDD at <unknown>:0"]; } subgraph cluster14153 { label="MapPartitions"; 6332 [labelType="html" label="MapPartitionsRDD [6332] toJavaRDD at <unknown>:0"]; } subgraph cluster14163 { label="mapPartitions"; 6334 [labelType="html" label="MapPartitionsRDD [6334] toJavaRDD at <unknown>:0"]; } } 6321->6322; 6322->6323; 6323->6324; 6324->6325; 6325->6326; 6326->6327; 6327->6328; 6328->6329; 6329->6330; 6330->6331; 6331->6332; 6332->6333; 6333->6334; 6334->6335; }

Event Timeline

Enable zooming