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

digraph G { subgraph clusterstage_1061 { label="Stage 1061"; 11156 [labelType="html" label="SQLExecutionRDD [11156] run at <unknown>:0"]; 11164 [labelType="html" label="SQLExecutionRDD [11164] toJavaRDD at <unknown>:0"]; 11166 [labelType="html" label="PythonRDD [11166] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster24958 { label="MicroBatchScan"; 11152 [labelType="html" label="DataSourceRDD [11152] run at <unknown>:0"]; 11153 [labelType="html" label="MapPartitionsRDD [11153] run at <unknown>:0"]; } subgraph cluster24957 { label="Project"; 11154 [labelType="html" label="MapPartitionsRDD [11154] run at <unknown>:0"]; } subgraph cluster24953 { label="WholeStageCodegen (1)"; 11155 [labelType="html" label="MapPartitionsRDD [11155] run at <unknown>:0"]; } subgraph cluster24967 { label="WholeStageCodegen (1)"; 11157 [labelType="html" label="MapPartitionsRDD [11157] toJavaRDD at <unknown>:0"]; } subgraph cluster24966 { label="Filter"; 11158 [labelType="html" label="MapPartitionsRDD [11158] toJavaRDD at <unknown>:0"]; } subgraph cluster24965 { label="Project"; 11159 [labelType="html" label="MapPartitionsRDD [11159] toJavaRDD at <unknown>:0"]; } subgraph cluster24962 { label="WholeStageCodegen (2)"; 11160 [labelType="html" label="MapPartitionsRDD [11160] toJavaRDD at <unknown>:0"]; } subgraph cluster24961 { label="Project"; 11161 [labelType="html" label="MapPartitionsRDD [11161] toJavaRDD at <unknown>:0"]; } subgraph cluster24960 { label="DeserializeToObject"; 11162 [labelType="html" label="MapPartitionsRDD [11162] toJavaRDD at <unknown>:0"]; } subgraph cluster24959 { label="MapPartitions"; 11163 [labelType="html" label="MapPartitionsRDD [11163] toJavaRDD at <unknown>:0"]; } subgraph cluster24969 { label="mapPartitions"; 11165 [labelType="html" label="MapPartitionsRDD [11165] toJavaRDD at <unknown>:0"]; } } 11152->11153; 11153->11154; 11154->11155; 11155->11156; 11156->11157; 11157->11158; 11158->11159; 11159->11160; 11160->11161; 11161->11162; 11162->11163; 11163->11164; 11164->11165; 11165->11166; }

Event Timeline

Enable zooming