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

digraph G { subgraph clusterstage_559 { label="Stage 559"; 5869 [labelType="html" label="SQLExecutionRDD [5869] run at <unknown>:0"]; 5877 [labelType="html" label="SQLExecutionRDD [5877] toJavaRDD at <unknown>:0"]; 5879 [labelType="html" label="PythonRDD [5879] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster13126 { label="MicroBatchScan"; 5865 [labelType="html" label="DataSourceRDD [5865] run at <unknown>:0"]; 5866 [labelType="html" label="MapPartitionsRDD [5866] run at <unknown>:0"]; } subgraph cluster13125 { label="Project"; 5867 [labelType="html" label="MapPartitionsRDD [5867] run at <unknown>:0"]; } subgraph cluster13121 { label="WholeStageCodegen (1)"; 5868 [labelType="html" label="MapPartitionsRDD [5868] run at <unknown>:0"]; } subgraph cluster13135 { label="WholeStageCodegen (1)"; 5870 [labelType="html" label="MapPartitionsRDD [5870] toJavaRDD at <unknown>:0"]; } subgraph cluster13134 { label="Filter"; 5871 [labelType="html" label="MapPartitionsRDD [5871] toJavaRDD at <unknown>:0"]; } subgraph cluster13133 { label="Project"; 5872 [labelType="html" label="MapPartitionsRDD [5872] toJavaRDD at <unknown>:0"]; } subgraph cluster13130 { label="WholeStageCodegen (2)"; 5873 [labelType="html" label="MapPartitionsRDD [5873] toJavaRDD at <unknown>:0"]; } subgraph cluster13129 { label="Project"; 5874 [labelType="html" label="MapPartitionsRDD [5874] toJavaRDD at <unknown>:0"]; } subgraph cluster13128 { label="DeserializeToObject"; 5875 [labelType="html" label="MapPartitionsRDD [5875] toJavaRDD at <unknown>:0"]; } subgraph cluster13127 { label="MapPartitions"; 5876 [labelType="html" label="MapPartitionsRDD [5876] toJavaRDD at <unknown>:0"]; } subgraph cluster13137 { label="mapPartitions"; 5878 [labelType="html" label="MapPartitionsRDD [5878] toJavaRDD at <unknown>:0"]; } } 5865->5866; 5866->5867; 5867->5868; 5868->5869; 5869->5870; 5870->5871; 5871->5872; 5872->5873; 5873->5874; 5874->5875; 5875->5876; 5876->5877; 5877->5878; 5878->5879; }

Event Timeline

Enable zooming