processing-stream-kafka-raw-to-minio - Details for Stage 252 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 3 s
Locality Level Summary: Process local: 3
Input Size / Records: 0.0 B / 474
Associated Job Ids: 252

digraph G { subgraph clusterstage_252 { label="Stage 252"; 2650 [labelType="html" label="SQLExecutionRDD [2650] run at <unknown>:0"]; 2658 [labelType="html" label="SQLExecutionRDD [2658] toJavaRDD at <unknown>:0"]; 2660 [labelType="html" label="PythonRDD [2660] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster5927 { label="MicroBatchScan"; 2646 [labelType="html" label="DataSourceRDD [2646] run at <unknown>:0"]; 2647 [labelType="html" label="MapPartitionsRDD [2647] run at <unknown>:0"]; } subgraph cluster5926 { label="Project"; 2648 [labelType="html" label="MapPartitionsRDD [2648] run at <unknown>:0"]; } subgraph cluster5922 { label="WholeStageCodegen (1)"; 2649 [labelType="html" label="MapPartitionsRDD [2649] run at <unknown>:0"]; } subgraph cluster5936 { label="WholeStageCodegen (1)"; 2651 [labelType="html" label="MapPartitionsRDD [2651] toJavaRDD at <unknown>:0"]; } subgraph cluster5935 { label="Filter"; 2652 [labelType="html" label="MapPartitionsRDD [2652] toJavaRDD at <unknown>:0"]; } subgraph cluster5934 { label="Project"; 2653 [labelType="html" label="MapPartitionsRDD [2653] toJavaRDD at <unknown>:0"]; } subgraph cluster5931 { label="WholeStageCodegen (2)"; 2654 [labelType="html" label="MapPartitionsRDD [2654] toJavaRDD at <unknown>:0"]; } subgraph cluster5930 { label="Project"; 2655 [labelType="html" label="MapPartitionsRDD [2655] toJavaRDD at <unknown>:0"]; } subgraph cluster5929 { label="DeserializeToObject"; 2656 [labelType="html" label="MapPartitionsRDD [2656] toJavaRDD at <unknown>:0"]; } subgraph cluster5928 { label="MapPartitions"; 2657 [labelType="html" label="MapPartitionsRDD [2657] toJavaRDD at <unknown>:0"]; } subgraph cluster5938 { label="mapPartitions"; 2659 [labelType="html" label="MapPartitionsRDD [2659] toJavaRDD at <unknown>:0"]; } } 2646->2647; 2647->2648; 2648->2649; 2649->2650; 2650->2651; 2651->2652; 2652->2653; 2653->2654; 2654->2655; 2655->2656; 2656->2657; 2657->2658; 2658->2659; 2659->2660; }

Event Timeline

Enable zooming