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

digraph G { subgraph clusterstage_2027 { label="Stage 2027"; 21299 [labelType="html" label="SQLExecutionRDD [21299] run at <unknown>:0"]; 21307 [labelType="html" label="SQLExecutionRDD [21307] toJavaRDD at <unknown>:0"]; 21309 [labelType="html" label="PythonRDD [21309] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster47659 { label="MicroBatchScan"; 21295 [labelType="html" label="DataSourceRDD [21295] run at <unknown>:0"]; 21296 [labelType="html" label="MapPartitionsRDD [21296] run at <unknown>:0"]; } subgraph cluster47658 { label="Project"; 21297 [labelType="html" label="MapPartitionsRDD [21297] run at <unknown>:0"]; } subgraph cluster47654 { label="WholeStageCodegen (1)"; 21298 [labelType="html" label="MapPartitionsRDD [21298] run at <unknown>:0"]; } subgraph cluster47668 { label="WholeStageCodegen (1)"; 21300 [labelType="html" label="MapPartitionsRDD [21300] toJavaRDD at <unknown>:0"]; } subgraph cluster47667 { label="Filter"; 21301 [labelType="html" label="MapPartitionsRDD [21301] toJavaRDD at <unknown>:0"]; } subgraph cluster47666 { label="Project"; 21302 [labelType="html" label="MapPartitionsRDD [21302] toJavaRDD at <unknown>:0"]; } subgraph cluster47663 { label="WholeStageCodegen (2)"; 21303 [labelType="html" label="MapPartitionsRDD [21303] toJavaRDD at <unknown>:0"]; } subgraph cluster47662 { label="Project"; 21304 [labelType="html" label="MapPartitionsRDD [21304] toJavaRDD at <unknown>:0"]; } subgraph cluster47661 { label="DeserializeToObject"; 21305 [labelType="html" label="MapPartitionsRDD [21305] toJavaRDD at <unknown>:0"]; } subgraph cluster47660 { label="MapPartitions"; 21306 [labelType="html" label="MapPartitionsRDD [21306] toJavaRDD at <unknown>:0"]; } subgraph cluster47670 { label="mapPartitions"; 21308 [labelType="html" label="MapPartitionsRDD [21308] toJavaRDD at <unknown>:0"]; } } 21295->21296; 21296->21297; 21297->21298; 21298->21299; 21299->21300; 21300->21301; 21301->21302; 21302->21303; 21303->21304; 21304->21305; 21305->21306; 21306->21307; 21307->21308; 21308->21309; }

Event Timeline

Enable zooming