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

digraph G { subgraph clusterstage_901 { label="Stage 901"; 9476 [labelType="html" label="SQLExecutionRDD [9476] run at <unknown>:0"]; 9484 [labelType="html" label="SQLExecutionRDD [9484] toJavaRDD at <unknown>:0"]; 9486 [labelType="html" label="PythonRDD [9486] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster21198 { label="MicroBatchScan"; 9472 [labelType="html" label="DataSourceRDD [9472] run at <unknown>:0"]; 9473 [labelType="html" label="MapPartitionsRDD [9473] run at <unknown>:0"]; } subgraph cluster21197 { label="Project"; 9474 [labelType="html" label="MapPartitionsRDD [9474] run at <unknown>:0"]; } subgraph cluster21193 { label="WholeStageCodegen (1)"; 9475 [labelType="html" label="MapPartitionsRDD [9475] run at <unknown>:0"]; } subgraph cluster21207 { label="WholeStageCodegen (1)"; 9477 [labelType="html" label="MapPartitionsRDD [9477] toJavaRDD at <unknown>:0"]; } subgraph cluster21206 { label="Filter"; 9478 [labelType="html" label="MapPartitionsRDD [9478] toJavaRDD at <unknown>:0"]; } subgraph cluster21205 { label="Project"; 9479 [labelType="html" label="MapPartitionsRDD [9479] toJavaRDD at <unknown>:0"]; } subgraph cluster21202 { label="WholeStageCodegen (2)"; 9480 [labelType="html" label="MapPartitionsRDD [9480] toJavaRDD at <unknown>:0"]; } subgraph cluster21201 { label="Project"; 9481 [labelType="html" label="MapPartitionsRDD [9481] toJavaRDD at <unknown>:0"]; } subgraph cluster21200 { label="DeserializeToObject"; 9482 [labelType="html" label="MapPartitionsRDD [9482] toJavaRDD at <unknown>:0"]; } subgraph cluster21199 { label="MapPartitions"; 9483 [labelType="html" label="MapPartitionsRDD [9483] toJavaRDD at <unknown>:0"]; } subgraph cluster21209 { label="mapPartitions"; 9485 [labelType="html" label="MapPartitionsRDD [9485] toJavaRDD at <unknown>:0"]; } } 9472->9473; 9473->9474; 9474->9475; 9475->9476; 9476->9477; 9477->9478; 9478->9479; 9479->9480; 9480->9481; 9481->9482; 9482->9483; 9483->9484; 9484->9485; 9485->9486; }

Event Timeline

Enable zooming