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

digraph G { subgraph clusterstage_541 { label="Stage 541"; 5680 [labelType="html" label="SQLExecutionRDD [5680] run at <unknown>:0"]; 5688 [labelType="html" label="SQLExecutionRDD [5688] toJavaRDD at <unknown>:0"]; 5690 [labelType="html" label="PythonRDD [5690] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster12703 { label="MicroBatchScan"; 5676 [labelType="html" label="DataSourceRDD [5676] run at <unknown>:0"]; 5677 [labelType="html" label="MapPartitionsRDD [5677] run at <unknown>:0"]; } subgraph cluster12702 { label="Project"; 5678 [labelType="html" label="MapPartitionsRDD [5678] run at <unknown>:0"]; } subgraph cluster12698 { label="WholeStageCodegen (1)"; 5679 [labelType="html" label="MapPartitionsRDD [5679] run at <unknown>:0"]; } subgraph cluster12712 { label="WholeStageCodegen (1)"; 5681 [labelType="html" label="MapPartitionsRDD [5681] toJavaRDD at <unknown>:0"]; } subgraph cluster12711 { label="Filter"; 5682 [labelType="html" label="MapPartitionsRDD [5682] toJavaRDD at <unknown>:0"]; } subgraph cluster12710 { label="Project"; 5683 [labelType="html" label="MapPartitionsRDD [5683] toJavaRDD at <unknown>:0"]; } subgraph cluster12707 { label="WholeStageCodegen (2)"; 5684 [labelType="html" label="MapPartitionsRDD [5684] toJavaRDD at <unknown>:0"]; } subgraph cluster12706 { label="Project"; 5685 [labelType="html" label="MapPartitionsRDD [5685] toJavaRDD at <unknown>:0"]; } subgraph cluster12705 { label="DeserializeToObject"; 5686 [labelType="html" label="MapPartitionsRDD [5686] toJavaRDD at <unknown>:0"]; } subgraph cluster12704 { label="MapPartitions"; 5687 [labelType="html" label="MapPartitionsRDD [5687] toJavaRDD at <unknown>:0"]; } subgraph cluster12714 { label="mapPartitions"; 5689 [labelType="html" label="MapPartitionsRDD [5689] toJavaRDD at <unknown>:0"]; } } 5676->5677; 5677->5678; 5678->5679; 5679->5680; 5680->5681; 5681->5682; 5682->5683; 5683->5684; 5684->5685; 5685->5686; 5686->5687; 5687->5688; 5688->5689; 5689->5690; }

Event Timeline

Enable zooming