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

digraph G { subgraph clusterstage_1544 { label="Stage 1544"; 16216 [labelType="html" label="SQLExecutionRDD [16216] run at <unknown>:0"]; 16224 [labelType="html" label="SQLExecutionRDD [16224] toJavaRDD at <unknown>:0"]; 16226 [labelType="html" label="PythonRDD [16226] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster36289 { label="MicroBatchScan"; 16212 [labelType="html" label="DataSourceRDD [16212] run at <unknown>:0"]; 16213 [labelType="html" label="MapPartitionsRDD [16213] run at <unknown>:0"]; } subgraph cluster36288 { label="Project"; 16214 [labelType="html" label="MapPartitionsRDD [16214] run at <unknown>:0"]; } subgraph cluster36284 { label="WholeStageCodegen (1)"; 16215 [labelType="html" label="MapPartitionsRDD [16215] run at <unknown>:0"]; } subgraph cluster36298 { label="WholeStageCodegen (1)"; 16217 [labelType="html" label="MapPartitionsRDD [16217] toJavaRDD at <unknown>:0"]; } subgraph cluster36297 { label="Filter"; 16218 [labelType="html" label="MapPartitionsRDD [16218] toJavaRDD at <unknown>:0"]; } subgraph cluster36296 { label="Project"; 16219 [labelType="html" label="MapPartitionsRDD [16219] toJavaRDD at <unknown>:0"]; } subgraph cluster36293 { label="WholeStageCodegen (2)"; 16220 [labelType="html" label="MapPartitionsRDD [16220] toJavaRDD at <unknown>:0"]; } subgraph cluster36292 { label="Project"; 16221 [labelType="html" label="MapPartitionsRDD [16221] toJavaRDD at <unknown>:0"]; } subgraph cluster36291 { label="DeserializeToObject"; 16222 [labelType="html" label="MapPartitionsRDD [16222] toJavaRDD at <unknown>:0"]; } subgraph cluster36290 { label="MapPartitions"; 16223 [labelType="html" label="MapPartitionsRDD [16223] toJavaRDD at <unknown>:0"]; } subgraph cluster36300 { label="mapPartitions"; 16225 [labelType="html" label="MapPartitionsRDD [16225] toJavaRDD at <unknown>:0"]; } } 16212->16213; 16213->16214; 16214->16215; 16215->16216; 16216->16217; 16217->16218; 16218->16219; 16219->16220; 16220->16221; 16221->16222; 16222->16223; 16223->16224; 16224->16225; 16225->16226; }

Event Timeline

Enable zooming