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

digraph G { subgraph clusterstage_1830 { label="Stage 1830"; 19219 [labelType="html" label="SQLExecutionRDD [19219] run at <unknown>:0"]; 19227 [labelType="html" label="SQLExecutionRDD [19227] toJavaRDD at <unknown>:0"]; 19229 [labelType="html" label="PythonRDD [19229] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster43010 { label="MicroBatchScan"; 19215 [labelType="html" label="DataSourceRDD [19215] run at <unknown>:0"]; 19216 [labelType="html" label="MapPartitionsRDD [19216] run at <unknown>:0"]; } subgraph cluster43009 { label="Project"; 19217 [labelType="html" label="MapPartitionsRDD [19217] run at <unknown>:0"]; } subgraph cluster43005 { label="WholeStageCodegen (1)"; 19218 [labelType="html" label="MapPartitionsRDD [19218] run at <unknown>:0"]; } subgraph cluster43019 { label="WholeStageCodegen (1)"; 19220 [labelType="html" label="MapPartitionsRDD [19220] toJavaRDD at <unknown>:0"]; } subgraph cluster43018 { label="Filter"; 19221 [labelType="html" label="MapPartitionsRDD [19221] toJavaRDD at <unknown>:0"]; } subgraph cluster43017 { label="Project"; 19222 [labelType="html" label="MapPartitionsRDD [19222] toJavaRDD at <unknown>:0"]; } subgraph cluster43014 { label="WholeStageCodegen (2)"; 19223 [labelType="html" label="MapPartitionsRDD [19223] toJavaRDD at <unknown>:0"]; } subgraph cluster43013 { label="Project"; 19224 [labelType="html" label="MapPartitionsRDD [19224] toJavaRDD at <unknown>:0"]; } subgraph cluster43012 { label="DeserializeToObject"; 19225 [labelType="html" label="MapPartitionsRDD [19225] toJavaRDD at <unknown>:0"]; } subgraph cluster43011 { label="MapPartitions"; 19226 [labelType="html" label="MapPartitionsRDD [19226] toJavaRDD at <unknown>:0"]; } subgraph cluster43021 { label="mapPartitions"; 19228 [labelType="html" label="MapPartitionsRDD [19228] toJavaRDD at <unknown>:0"]; } } 19215->19216; 19216->19217; 19217->19218; 19218->19219; 19219->19220; 19220->19221; 19221->19222; 19222->19223; 19223->19224; 19224->19225; 19225->19226; 19226->19227; 19227->19228; 19228->19229; }

Event Timeline

Enable zooming