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

digraph G { subgraph clusterstage_344 { label="Stage 344"; 3616 [labelType="html" label="SQLExecutionRDD [3616] run at <unknown>:0"]; 3624 [labelType="html" label="SQLExecutionRDD [3624] toJavaRDD at <unknown>:0"]; 3626 [labelType="html" label="PythonRDD [3626] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster8089 { label="MicroBatchScan"; 3612 [labelType="html" label="DataSourceRDD [3612] run at <unknown>:0"]; 3613 [labelType="html" label="MapPartitionsRDD [3613] run at <unknown>:0"]; } subgraph cluster8088 { label="Project"; 3614 [labelType="html" label="MapPartitionsRDD [3614] run at <unknown>:0"]; } subgraph cluster8084 { label="WholeStageCodegen (1)"; 3615 [labelType="html" label="MapPartitionsRDD [3615] run at <unknown>:0"]; } subgraph cluster8098 { label="WholeStageCodegen (1)"; 3617 [labelType="html" label="MapPartitionsRDD [3617] toJavaRDD at <unknown>:0"]; } subgraph cluster8097 { label="Filter"; 3618 [labelType="html" label="MapPartitionsRDD [3618] toJavaRDD at <unknown>:0"]; } subgraph cluster8096 { label="Project"; 3619 [labelType="html" label="MapPartitionsRDD [3619] toJavaRDD at <unknown>:0"]; } subgraph cluster8093 { label="WholeStageCodegen (2)"; 3620 [labelType="html" label="MapPartitionsRDD [3620] toJavaRDD at <unknown>:0"]; } subgraph cluster8092 { label="Project"; 3621 [labelType="html" label="MapPartitionsRDD [3621] toJavaRDD at <unknown>:0"]; } subgraph cluster8091 { label="DeserializeToObject"; 3622 [labelType="html" label="MapPartitionsRDD [3622] toJavaRDD at <unknown>:0"]; } subgraph cluster8090 { label="MapPartitions"; 3623 [labelType="html" label="MapPartitionsRDD [3623] toJavaRDD at <unknown>:0"]; } subgraph cluster8100 { label="mapPartitions"; 3625 [labelType="html" label="MapPartitionsRDD [3625] toJavaRDD at <unknown>:0"]; } } 3612->3613; 3613->3614; 3614->3615; 3615->3616; 3616->3617; 3617->3618; 3618->3619; 3619->3620; 3620->3621; 3621->3622; 3622->3623; 3623->3624; 3624->3625; 3625->3626; }

Event Timeline

Enable zooming