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

digraph G { subgraph clusterstage_458 { label="Stage 458"; 4813 [labelType="html" label="SQLExecutionRDD [4813] run at <unknown>:0"]; 4821 [labelType="html" label="SQLExecutionRDD [4821] toJavaRDD at <unknown>:0"]; 4823 [labelType="html" label="PythonRDD [4823] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster10768 { label="MicroBatchScan"; 4809 [labelType="html" label="DataSourceRDD [4809] run at <unknown>:0"]; 4810 [labelType="html" label="MapPartitionsRDD [4810] run at <unknown>:0"]; } subgraph cluster10767 { label="Project"; 4811 [labelType="html" label="MapPartitionsRDD [4811] run at <unknown>:0"]; } subgraph cluster10763 { label="WholeStageCodegen (1)"; 4812 [labelType="html" label="MapPartitionsRDD [4812] run at <unknown>:0"]; } subgraph cluster10777 { label="WholeStageCodegen (1)"; 4814 [labelType="html" label="MapPartitionsRDD [4814] toJavaRDD at <unknown>:0"]; } subgraph cluster10776 { label="Filter"; 4815 [labelType="html" label="MapPartitionsRDD [4815] toJavaRDD at <unknown>:0"]; } subgraph cluster10775 { label="Project"; 4816 [labelType="html" label="MapPartitionsRDD [4816] toJavaRDD at <unknown>:0"]; } subgraph cluster10772 { label="WholeStageCodegen (2)"; 4817 [labelType="html" label="MapPartitionsRDD [4817] toJavaRDD at <unknown>:0"]; } subgraph cluster10771 { label="Project"; 4818 [labelType="html" label="MapPartitionsRDD [4818] toJavaRDD at <unknown>:0"]; } subgraph cluster10770 { label="DeserializeToObject"; 4819 [labelType="html" label="MapPartitionsRDD [4819] toJavaRDD at <unknown>:0"]; } subgraph cluster10769 { label="MapPartitions"; 4820 [labelType="html" label="MapPartitionsRDD [4820] toJavaRDD at <unknown>:0"]; } subgraph cluster10779 { label="mapPartitions"; 4822 [labelType="html" label="MapPartitionsRDD [4822] toJavaRDD at <unknown>:0"]; } } 4809->4810; 4810->4811; 4811->4812; 4812->4813; 4813->4814; 4814->4815; 4815->4816; 4816->4817; 4817->4818; 4818->4819; 4819->4820; 4820->4821; 4821->4822; 4822->4823; }

Event Timeline

Enable zooming