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

digraph G { subgraph clusterstage_1790 { label="Stage 1790"; 18799 [labelType="html" label="SQLExecutionRDD [18799] run at <unknown>:0"]; 18807 [labelType="html" label="SQLExecutionRDD [18807] toJavaRDD at <unknown>:0"]; 18809 [labelType="html" label="PythonRDD [18809] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster42070 { label="MicroBatchScan"; 18795 [labelType="html" label="DataSourceRDD [18795] run at <unknown>:0"]; 18796 [labelType="html" label="MapPartitionsRDD [18796] run at <unknown>:0"]; } subgraph cluster42069 { label="Project"; 18797 [labelType="html" label="MapPartitionsRDD [18797] run at <unknown>:0"]; } subgraph cluster42065 { label="WholeStageCodegen (1)"; 18798 [labelType="html" label="MapPartitionsRDD [18798] run at <unknown>:0"]; } subgraph cluster42079 { label="WholeStageCodegen (1)"; 18800 [labelType="html" label="MapPartitionsRDD [18800] toJavaRDD at <unknown>:0"]; } subgraph cluster42078 { label="Filter"; 18801 [labelType="html" label="MapPartitionsRDD [18801] toJavaRDD at <unknown>:0"]; } subgraph cluster42077 { label="Project"; 18802 [labelType="html" label="MapPartitionsRDD [18802] toJavaRDD at <unknown>:0"]; } subgraph cluster42074 { label="WholeStageCodegen (2)"; 18803 [labelType="html" label="MapPartitionsRDD [18803] toJavaRDD at <unknown>:0"]; } subgraph cluster42073 { label="Project"; 18804 [labelType="html" label="MapPartitionsRDD [18804] toJavaRDD at <unknown>:0"]; } subgraph cluster42072 { label="DeserializeToObject"; 18805 [labelType="html" label="MapPartitionsRDD [18805] toJavaRDD at <unknown>:0"]; } subgraph cluster42071 { label="MapPartitions"; 18806 [labelType="html" label="MapPartitionsRDD [18806] toJavaRDD at <unknown>:0"]; } subgraph cluster42081 { label="mapPartitions"; 18808 [labelType="html" label="MapPartitionsRDD [18808] toJavaRDD at <unknown>:0"]; } } 18795->18796; 18796->18797; 18797->18798; 18798->18799; 18799->18800; 18800->18801; 18801->18802; 18802->18803; 18803->18804; 18804->18805; 18805->18806; 18806->18807; 18807->18808; 18808->18809; }

Event Timeline

Enable zooming