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

digraph G { subgraph clusterstage_45 { label="Stage 45"; 466 [labelType="html" label="SQLExecutionRDD [466] run at <unknown>:0"]; 480 [labelType="html" label="SQLExecutionRDD [480] toJavaRDD at <unknown>:0"]; 482 [labelType="html" label="PythonRDD [482] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster1039 { label="MicroBatchScan"; 462 [labelType="html" label="DataSourceRDD [462] run at <unknown>:0"]; 463 [labelType="html" label="MapPartitionsRDD [463] run at <unknown>:0"]; } subgraph cluster1038 { label="Project"; 464 [labelType="html" label="MapPartitionsRDD [464] run at <unknown>:0"]; } subgraph cluster1034 { label="WholeStageCodegen (1)"; 465 [labelType="html" label="MapPartitionsRDD [465] run at <unknown>:0"]; } subgraph cluster1056 { label="WholeStageCodegen (1)"; 473 [labelType="html" label="MapPartitionsRDD [473] toJavaRDD at <unknown>:0"]; } subgraph cluster1055 { label="Filter"; 474 [labelType="html" label="MapPartitionsRDD [474] toJavaRDD at <unknown>:0"]; } subgraph cluster1054 { label="Project"; 475 [labelType="html" label="MapPartitionsRDD [475] toJavaRDD at <unknown>:0"]; } subgraph cluster1051 { label="WholeStageCodegen (2)"; 476 [labelType="html" label="MapPartitionsRDD [476] toJavaRDD at <unknown>:0"]; } subgraph cluster1050 { label="Project"; 477 [labelType="html" label="MapPartitionsRDD [477] toJavaRDD at <unknown>:0"]; } subgraph cluster1049 { label="DeserializeToObject"; 478 [labelType="html" label="MapPartitionsRDD [478] toJavaRDD at <unknown>:0"]; } subgraph cluster1048 { label="MapPartitions"; 479 [labelType="html" label="MapPartitionsRDD [479] toJavaRDD at <unknown>:0"]; } subgraph cluster1058 { label="mapPartitions"; 481 [labelType="html" label="MapPartitionsRDD [481] toJavaRDD at <unknown>:0"]; } } 462->463; 463->464; 464->465; 465->466; 466->473; 473->474; 474->475; 475->476; 476->477; 477->478; 478->479; 479->480; 480->481; 481->482; }

Event Timeline

Enable zooming