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

digraph G { subgraph clusterstage_554 { label="Stage 554"; 5821 [labelType="html" label="SQLExecutionRDD [5821] run at <unknown>:0"]; 5829 [labelType="html" label="SQLExecutionRDD [5829] toJavaRDD at <unknown>:0"]; 5831 [labelType="html" label="PythonRDD [5831] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster13024 { label="MicroBatchScan"; 5817 [labelType="html" label="DataSourceRDD [5817] run at <unknown>:0"]; 5818 [labelType="html" label="MapPartitionsRDD [5818] run at <unknown>:0"]; } subgraph cluster13023 { label="Project"; 5819 [labelType="html" label="MapPartitionsRDD [5819] run at <unknown>:0"]; } subgraph cluster13019 { label="WholeStageCodegen (1)"; 5820 [labelType="html" label="MapPartitionsRDD [5820] run at <unknown>:0"]; } subgraph cluster13033 { label="WholeStageCodegen (1)"; 5822 [labelType="html" label="MapPartitionsRDD [5822] toJavaRDD at <unknown>:0"]; } subgraph cluster13032 { label="Filter"; 5823 [labelType="html" label="MapPartitionsRDD [5823] toJavaRDD at <unknown>:0"]; } subgraph cluster13031 { label="Project"; 5824 [labelType="html" label="MapPartitionsRDD [5824] toJavaRDD at <unknown>:0"]; } subgraph cluster13028 { label="WholeStageCodegen (2)"; 5825 [labelType="html" label="MapPartitionsRDD [5825] toJavaRDD at <unknown>:0"]; } subgraph cluster13027 { label="Project"; 5826 [labelType="html" label="MapPartitionsRDD [5826] toJavaRDD at <unknown>:0"]; } subgraph cluster13026 { label="DeserializeToObject"; 5827 [labelType="html" label="MapPartitionsRDD [5827] toJavaRDD at <unknown>:0"]; } subgraph cluster13025 { label="MapPartitions"; 5828 [labelType="html" label="MapPartitionsRDD [5828] toJavaRDD at <unknown>:0"]; } subgraph cluster13035 { label="mapPartitions"; 5830 [labelType="html" label="MapPartitionsRDD [5830] toJavaRDD at <unknown>:0"]; } } 5817->5818; 5818->5819; 5819->5820; 5820->5821; 5821->5822; 5822->5823; 5823->5824; 5824->5825; 5825->5826; 5826->5827; 5827->5828; 5828->5829; 5829->5830; 5830->5831; }

Event Timeline

Enable zooming