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

digraph G { subgraph clusterstage_1735 { label="Stage 1735"; 18217 [labelType="html" label="SQLExecutionRDD [18217] run at <unknown>:0"]; 18225 [labelType="html" label="SQLExecutionRDD [18225] toJavaRDD at <unknown>:0"]; 18227 [labelType="html" label="PythonRDD [18227] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster40762 { label="MicroBatchScan"; 18213 [labelType="html" label="DataSourceRDD [18213] run at <unknown>:0"]; 18214 [labelType="html" label="MapPartitionsRDD [18214] run at <unknown>:0"]; } subgraph cluster40761 { label="Project"; 18215 [labelType="html" label="MapPartitionsRDD [18215] run at <unknown>:0"]; } subgraph cluster40757 { label="WholeStageCodegen (1)"; 18216 [labelType="html" label="MapPartitionsRDD [18216] run at <unknown>:0"]; } subgraph cluster40771 { label="WholeStageCodegen (1)"; 18218 [labelType="html" label="MapPartitionsRDD [18218] toJavaRDD at <unknown>:0"]; } subgraph cluster40770 { label="Filter"; 18219 [labelType="html" label="MapPartitionsRDD [18219] toJavaRDD at <unknown>:0"]; } subgraph cluster40769 { label="Project"; 18220 [labelType="html" label="MapPartitionsRDD [18220] toJavaRDD at <unknown>:0"]; } subgraph cluster40766 { label="WholeStageCodegen (2)"; 18221 [labelType="html" label="MapPartitionsRDD [18221] toJavaRDD at <unknown>:0"]; } subgraph cluster40765 { label="Project"; 18222 [labelType="html" label="MapPartitionsRDD [18222] toJavaRDD at <unknown>:0"]; } subgraph cluster40764 { label="DeserializeToObject"; 18223 [labelType="html" label="MapPartitionsRDD [18223] toJavaRDD at <unknown>:0"]; } subgraph cluster40763 { label="MapPartitions"; 18224 [labelType="html" label="MapPartitionsRDD [18224] toJavaRDD at <unknown>:0"]; } subgraph cluster40773 { label="mapPartitions"; 18226 [labelType="html" label="MapPartitionsRDD [18226] toJavaRDD at <unknown>:0"]; } } 18213->18214; 18214->18215; 18215->18216; 18216->18217; 18217->18218; 18218->18219; 18219->18220; 18220->18221; 18221->18222; 18222->18223; 18223->18224; 18224->18225; 18225->18226; 18226->18227; }

Event Timeline

Enable zooming