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

digraph G { subgraph clusterstage_456 { label="Stage 456"; 4793 [labelType="html" label="SQLExecutionRDD [4793] run at <unknown>:0"]; 4807 [labelType="html" label="SQLExecutionRDD [4807] toJavaRDD at <unknown>:0"]; 4809 [labelType="html" label="PythonRDD [4809] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster10717 { label="MicroBatchScan"; 4789 [labelType="html" label="DataSourceRDD [4789] run at <unknown>:0"]; 4790 [labelType="html" label="MapPartitionsRDD [4790] run at <unknown>:0"]; } subgraph cluster10716 { label="Project"; 4791 [labelType="html" label="MapPartitionsRDD [4791] run at <unknown>:0"]; } subgraph cluster10712 { label="WholeStageCodegen (1)"; 4792 [labelType="html" label="MapPartitionsRDD [4792] run at <unknown>:0"]; } subgraph cluster10734 { label="WholeStageCodegen (1)"; 4800 [labelType="html" label="MapPartitionsRDD [4800] toJavaRDD at <unknown>:0"]; } subgraph cluster10733 { label="Filter"; 4801 [labelType="html" label="MapPartitionsRDD [4801] toJavaRDD at <unknown>:0"]; } subgraph cluster10732 { label="Project"; 4802 [labelType="html" label="MapPartitionsRDD [4802] toJavaRDD at <unknown>:0"]; } subgraph cluster10729 { label="WholeStageCodegen (2)"; 4803 [labelType="html" label="MapPartitionsRDD [4803] toJavaRDD at <unknown>:0"]; } subgraph cluster10728 { label="Project"; 4804 [labelType="html" label="MapPartitionsRDD [4804] toJavaRDD at <unknown>:0"]; } subgraph cluster10727 { label="DeserializeToObject"; 4805 [labelType="html" label="MapPartitionsRDD [4805] toJavaRDD at <unknown>:0"]; } subgraph cluster10726 { label="MapPartitions"; 4806 [labelType="html" label="MapPartitionsRDD [4806] toJavaRDD at <unknown>:0"]; } subgraph cluster10736 { label="mapPartitions"; 4808 [labelType="html" label="MapPartitionsRDD [4808] toJavaRDD at <unknown>:0"]; } } 4789->4790; 4790->4791; 4791->4792; 4792->4793; 4793->4800; 4800->4801; 4801->4802; 4802->4803; 4803->4804; 4804->4805; 4805->4806; 4806->4807; 4807->4808; 4808->4809; }

Event Timeline

Enable zooming