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

digraph G { subgraph clusterstage_71 { label="Stage 71"; 739 [labelType="html" label="SQLExecutionRDD [739] run at <unknown>:0"]; 753 [labelType="html" label="SQLExecutionRDD [753] toJavaRDD at <unknown>:0"]; 755 [labelType="html" label="PythonRDD [755] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster1650 { label="MicroBatchScan"; 735 [labelType="html" label="DataSourceRDD [735] run at <unknown>:0"]; 736 [labelType="html" label="MapPartitionsRDD [736] run at <unknown>:0"]; } subgraph cluster1649 { label="Project"; 737 [labelType="html" label="MapPartitionsRDD [737] run at <unknown>:0"]; } subgraph cluster1645 { label="WholeStageCodegen (1)"; 738 [labelType="html" label="MapPartitionsRDD [738] run at <unknown>:0"]; } subgraph cluster1667 { label="WholeStageCodegen (1)"; 746 [labelType="html" label="MapPartitionsRDD [746] toJavaRDD at <unknown>:0"]; } subgraph cluster1666 { label="Filter"; 747 [labelType="html" label="MapPartitionsRDD [747] toJavaRDD at <unknown>:0"]; } subgraph cluster1665 { label="Project"; 748 [labelType="html" label="MapPartitionsRDD [748] toJavaRDD at <unknown>:0"]; } subgraph cluster1662 { label="WholeStageCodegen (2)"; 749 [labelType="html" label="MapPartitionsRDD [749] toJavaRDD at <unknown>:0"]; } subgraph cluster1661 { label="Project"; 750 [labelType="html" label="MapPartitionsRDD [750] toJavaRDD at <unknown>:0"]; } subgraph cluster1660 { label="DeserializeToObject"; 751 [labelType="html" label="MapPartitionsRDD [751] toJavaRDD at <unknown>:0"]; } subgraph cluster1659 { label="MapPartitions"; 752 [labelType="html" label="MapPartitionsRDD [752] toJavaRDD at <unknown>:0"]; } subgraph cluster1669 { label="mapPartitions"; 754 [labelType="html" label="MapPartitionsRDD [754] toJavaRDD at <unknown>:0"]; } } 735->736; 736->737; 737->738; 738->739; 739->746; 746->747; 747->748; 748->749; 749->750; 750->751; 751->752; 752->753; 753->754; 754->755; }

Event Timeline

Enable zooming