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

digraph G { subgraph clusterstage_1093 { label="Stage 1093"; 11492 [labelType="html" label="SQLExecutionRDD [11492] run at <unknown>:0"]; 11500 [labelType="html" label="SQLExecutionRDD [11500] toJavaRDD at <unknown>:0"]; 11502 [labelType="html" label="PythonRDD [11502] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster25710 { label="MicroBatchScan"; 11488 [labelType="html" label="DataSourceRDD [11488] run at <unknown>:0"]; 11489 [labelType="html" label="MapPartitionsRDD [11489] run at <unknown>:0"]; } subgraph cluster25709 { label="Project"; 11490 [labelType="html" label="MapPartitionsRDD [11490] run at <unknown>:0"]; } subgraph cluster25705 { label="WholeStageCodegen (1)"; 11491 [labelType="html" label="MapPartitionsRDD [11491] run at <unknown>:0"]; } subgraph cluster25719 { label="WholeStageCodegen (1)"; 11493 [labelType="html" label="MapPartitionsRDD [11493] toJavaRDD at <unknown>:0"]; } subgraph cluster25718 { label="Filter"; 11494 [labelType="html" label="MapPartitionsRDD [11494] toJavaRDD at <unknown>:0"]; } subgraph cluster25717 { label="Project"; 11495 [labelType="html" label="MapPartitionsRDD [11495] toJavaRDD at <unknown>:0"]; } subgraph cluster25714 { label="WholeStageCodegen (2)"; 11496 [labelType="html" label="MapPartitionsRDD [11496] toJavaRDD at <unknown>:0"]; } subgraph cluster25713 { label="Project"; 11497 [labelType="html" label="MapPartitionsRDD [11497] toJavaRDD at <unknown>:0"]; } subgraph cluster25712 { label="DeserializeToObject"; 11498 [labelType="html" label="MapPartitionsRDD [11498] toJavaRDD at <unknown>:0"]; } subgraph cluster25711 { label="MapPartitions"; 11499 [labelType="html" label="MapPartitionsRDD [11499] toJavaRDD at <unknown>:0"]; } subgraph cluster25721 { label="mapPartitions"; 11501 [labelType="html" label="MapPartitionsRDD [11501] toJavaRDD at <unknown>:0"]; } } 11488->11489; 11489->11490; 11490->11491; 11491->11492; 11492->11493; 11493->11494; 11494->11495; 11495->11496; 11496->11497; 11497->11498; 11498->11499; 11499->11500; 11500->11501; 11501->11502; }

Event Timeline

Enable zooming