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

digraph G { subgraph clusterstage_1379 { label="Stage 1379"; 14495 [labelType="html" label="SQLExecutionRDD [14495] run at <unknown>:0"]; 14503 [labelType="html" label="SQLExecutionRDD [14503] toJavaRDD at <unknown>:0"]; 14505 [labelType="html" label="PythonRDD [14505] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster32431 { label="MicroBatchScan"; 14491 [labelType="html" label="DataSourceRDD [14491] run at <unknown>:0"]; 14492 [labelType="html" label="MapPartitionsRDD [14492] run at <unknown>:0"]; } subgraph cluster32430 { label="Project"; 14493 [labelType="html" label="MapPartitionsRDD [14493] run at <unknown>:0"]; } subgraph cluster32426 { label="WholeStageCodegen (1)"; 14494 [labelType="html" label="MapPartitionsRDD [14494] run at <unknown>:0"]; } subgraph cluster32440 { label="WholeStageCodegen (1)"; 14496 [labelType="html" label="MapPartitionsRDD [14496] toJavaRDD at <unknown>:0"]; } subgraph cluster32439 { label="Filter"; 14497 [labelType="html" label="MapPartitionsRDD [14497] toJavaRDD at <unknown>:0"]; } subgraph cluster32438 { label="Project"; 14498 [labelType="html" label="MapPartitionsRDD [14498] toJavaRDD at <unknown>:0"]; } subgraph cluster32435 { label="WholeStageCodegen (2)"; 14499 [labelType="html" label="MapPartitionsRDD [14499] toJavaRDD at <unknown>:0"]; } subgraph cluster32434 { label="Project"; 14500 [labelType="html" label="MapPartitionsRDD [14500] toJavaRDD at <unknown>:0"]; } subgraph cluster32433 { label="DeserializeToObject"; 14501 [labelType="html" label="MapPartitionsRDD [14501] toJavaRDD at <unknown>:0"]; } subgraph cluster32432 { label="MapPartitions"; 14502 [labelType="html" label="MapPartitionsRDD [14502] toJavaRDD at <unknown>:0"]; } subgraph cluster32442 { label="mapPartitions"; 14504 [labelType="html" label="MapPartitionsRDD [14504] toJavaRDD at <unknown>:0"]; } } 14491->14492; 14492->14493; 14493->14494; 14494->14495; 14495->14496; 14496->14497; 14497->14498; 14498->14499; 14499->14500; 14500->14501; 14501->14502; 14502->14503; 14503->14504; 14504->14505; }

Event Timeline

Enable zooming