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

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 4
Input Size / Records: 0.0 B / 550
Associated Job Ids: 266

digraph G { subgraph clusterstage_266 { label="Stage 266"; 2797 [labelType="html" label="SQLExecutionRDD [2797] run at <unknown>:0"]; 2805 [labelType="html" label="SQLExecutionRDD [2805] toJavaRDD at <unknown>:0"]; 2807 [labelType="html" label="PythonRDD [2807] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster6256 { label="MicroBatchScan"; 2793 [labelType="html" label="DataSourceRDD [2793] run at <unknown>:0"]; 2794 [labelType="html" label="MapPartitionsRDD [2794] run at <unknown>:0"]; } subgraph cluster6255 { label="Project"; 2795 [labelType="html" label="MapPartitionsRDD [2795] run at <unknown>:0"]; } subgraph cluster6251 { label="WholeStageCodegen (1)"; 2796 [labelType="html" label="MapPartitionsRDD [2796] run at <unknown>:0"]; } subgraph cluster6265 { label="WholeStageCodegen (1)"; 2798 [labelType="html" label="MapPartitionsRDD [2798] toJavaRDD at <unknown>:0"]; } subgraph cluster6264 { label="Filter"; 2799 [labelType="html" label="MapPartitionsRDD [2799] toJavaRDD at <unknown>:0"]; } subgraph cluster6263 { label="Project"; 2800 [labelType="html" label="MapPartitionsRDD [2800] toJavaRDD at <unknown>:0"]; } subgraph cluster6260 { label="WholeStageCodegen (2)"; 2801 [labelType="html" label="MapPartitionsRDD [2801] toJavaRDD at <unknown>:0"]; } subgraph cluster6259 { label="Project"; 2802 [labelType="html" label="MapPartitionsRDD [2802] toJavaRDD at <unknown>:0"]; } subgraph cluster6258 { label="DeserializeToObject"; 2803 [labelType="html" label="MapPartitionsRDD [2803] toJavaRDD at <unknown>:0"]; } subgraph cluster6257 { label="MapPartitions"; 2804 [labelType="html" label="MapPartitionsRDD [2804] toJavaRDD at <unknown>:0"]; } subgraph cluster6267 { label="mapPartitions"; 2806 [labelType="html" label="MapPartitionsRDD [2806] toJavaRDD at <unknown>:0"]; } } 2793->2794; 2794->2795; 2795->2796; 2796->2797; 2797->2798; 2798->2799; 2799->2800; 2800->2801; 2801->2802; 2802->2803; 2803->2804; 2804->2805; 2805->2806; 2806->2807; }

Event Timeline

Enable zooming