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

digraph G { subgraph clusterstage_1021 { label="Stage 1021"; 10736 [labelType="html" label="SQLExecutionRDD [10736] run at <unknown>:0"]; 10744 [labelType="html" label="SQLExecutionRDD [10744] toJavaRDD at <unknown>:0"]; 10746 [labelType="html" label="PythonRDD [10746] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster24018 { label="MicroBatchScan"; 10732 [labelType="html" label="DataSourceRDD [10732] run at <unknown>:0"]; 10733 [labelType="html" label="MapPartitionsRDD [10733] run at <unknown>:0"]; } subgraph cluster24017 { label="Project"; 10734 [labelType="html" label="MapPartitionsRDD [10734] run at <unknown>:0"]; } subgraph cluster24013 { label="WholeStageCodegen (1)"; 10735 [labelType="html" label="MapPartitionsRDD [10735] run at <unknown>:0"]; } subgraph cluster24027 { label="WholeStageCodegen (1)"; 10737 [labelType="html" label="MapPartitionsRDD [10737] toJavaRDD at <unknown>:0"]; } subgraph cluster24026 { label="Filter"; 10738 [labelType="html" label="MapPartitionsRDD [10738] toJavaRDD at <unknown>:0"]; } subgraph cluster24025 { label="Project"; 10739 [labelType="html" label="MapPartitionsRDD [10739] toJavaRDD at <unknown>:0"]; } subgraph cluster24022 { label="WholeStageCodegen (2)"; 10740 [labelType="html" label="MapPartitionsRDD [10740] toJavaRDD at <unknown>:0"]; } subgraph cluster24021 { label="Project"; 10741 [labelType="html" label="MapPartitionsRDD [10741] toJavaRDD at <unknown>:0"]; } subgraph cluster24020 { label="DeserializeToObject"; 10742 [labelType="html" label="MapPartitionsRDD [10742] toJavaRDD at <unknown>:0"]; } subgraph cluster24019 { label="MapPartitions"; 10743 [labelType="html" label="MapPartitionsRDD [10743] toJavaRDD at <unknown>:0"]; } subgraph cluster24029 { label="mapPartitions"; 10745 [labelType="html" label="MapPartitionsRDD [10745] toJavaRDD at <unknown>:0"]; } } 10732->10733; 10733->10734; 10734->10735; 10735->10736; 10736->10737; 10737->10738; 10738->10739; 10739->10740; 10740->10741; 10741->10742; 10742->10743; 10743->10744; 10744->10745; 10745->10746; }

Event Timeline

Enable zooming