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

digraph G { subgraph clusterstage_1769 { label="Stage 1769"; 18574 [labelType="html" label="SQLExecutionRDD [18574] run at <unknown>:0"]; 18582 [labelType="html" label="SQLExecutionRDD [18582] toJavaRDD at <unknown>:0"]; 18584 [labelType="html" label="PythonRDD [18584] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster41561 { label="MicroBatchScan"; 18570 [labelType="html" label="DataSourceRDD [18570] run at <unknown>:0"]; 18571 [labelType="html" label="MapPartitionsRDD [18571] run at <unknown>:0"]; } subgraph cluster41560 { label="Project"; 18572 [labelType="html" label="MapPartitionsRDD [18572] run at <unknown>:0"]; } subgraph cluster41556 { label="WholeStageCodegen (1)"; 18573 [labelType="html" label="MapPartitionsRDD [18573] run at <unknown>:0"]; } subgraph cluster41570 { label="WholeStageCodegen (1)"; 18575 [labelType="html" label="MapPartitionsRDD [18575] toJavaRDD at <unknown>:0"]; } subgraph cluster41569 { label="Filter"; 18576 [labelType="html" label="MapPartitionsRDD [18576] toJavaRDD at <unknown>:0"]; } subgraph cluster41568 { label="Project"; 18577 [labelType="html" label="MapPartitionsRDD [18577] toJavaRDD at <unknown>:0"]; } subgraph cluster41565 { label="WholeStageCodegen (2)"; 18578 [labelType="html" label="MapPartitionsRDD [18578] toJavaRDD at <unknown>:0"]; } subgraph cluster41564 { label="Project"; 18579 [labelType="html" label="MapPartitionsRDD [18579] toJavaRDD at <unknown>:0"]; } subgraph cluster41563 { label="DeserializeToObject"; 18580 [labelType="html" label="MapPartitionsRDD [18580] toJavaRDD at <unknown>:0"]; } subgraph cluster41562 { label="MapPartitions"; 18581 [labelType="html" label="MapPartitionsRDD [18581] toJavaRDD at <unknown>:0"]; } subgraph cluster41572 { label="mapPartitions"; 18583 [labelType="html" label="MapPartitionsRDD [18583] toJavaRDD at <unknown>:0"]; } } 18570->18571; 18571->18572; 18572->18573; 18573->18574; 18574->18575; 18575->18576; 18576->18577; 18577->18578; 18578->18579; 18579->18580; 18580->18581; 18581->18582; 18582->18583; 18583->18584; }

Event Timeline

Enable zooming