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

digraph G { subgraph clusterstage_1949 { label="Stage 1949"; 20480 [labelType="html" label="SQLExecutionRDD [20480] run at <unknown>:0"]; 20488 [labelType="html" label="SQLExecutionRDD [20488] toJavaRDD at <unknown>:0"]; 20490 [labelType="html" label="PythonRDD [20490] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster45826 { label="MicroBatchScan"; 20476 [labelType="html" label="DataSourceRDD [20476] run at <unknown>:0"]; 20477 [labelType="html" label="MapPartitionsRDD [20477] run at <unknown>:0"]; } subgraph cluster45825 { label="Project"; 20478 [labelType="html" label="MapPartitionsRDD [20478] run at <unknown>:0"]; } subgraph cluster45821 { label="WholeStageCodegen (1)"; 20479 [labelType="html" label="MapPartitionsRDD [20479] run at <unknown>:0"]; } subgraph cluster45835 { label="WholeStageCodegen (1)"; 20481 [labelType="html" label="MapPartitionsRDD [20481] toJavaRDD at <unknown>:0"]; } subgraph cluster45834 { label="Filter"; 20482 [labelType="html" label="MapPartitionsRDD [20482] toJavaRDD at <unknown>:0"]; } subgraph cluster45833 { label="Project"; 20483 [labelType="html" label="MapPartitionsRDD [20483] toJavaRDD at <unknown>:0"]; } subgraph cluster45830 { label="WholeStageCodegen (2)"; 20484 [labelType="html" label="MapPartitionsRDD [20484] toJavaRDD at <unknown>:0"]; } subgraph cluster45829 { label="Project"; 20485 [labelType="html" label="MapPartitionsRDD [20485] toJavaRDD at <unknown>:0"]; } subgraph cluster45828 { label="DeserializeToObject"; 20486 [labelType="html" label="MapPartitionsRDD [20486] toJavaRDD at <unknown>:0"]; } subgraph cluster45827 { label="MapPartitions"; 20487 [labelType="html" label="MapPartitionsRDD [20487] toJavaRDD at <unknown>:0"]; } subgraph cluster45837 { label="mapPartitions"; 20489 [labelType="html" label="MapPartitionsRDD [20489] toJavaRDD at <unknown>:0"]; } } 20476->20477; 20477->20478; 20478->20479; 20479->20480; 20480->20481; 20481->20482; 20482->20483; 20483->20484; 20484->20485; 20485->20486; 20486->20487; 20487->20488; 20488->20489; 20489->20490; }

Event Timeline

Enable zooming