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

digraph G { subgraph clusterstage_1056 { label="Stage 1056"; 11093 [labelType="html" label="SQLExecutionRDD [11093] run at <unknown>:0"]; 11107 [labelType="html" label="SQLExecutionRDD [11107] toJavaRDD at <unknown>:0"]; 11109 [labelType="html" label="PythonRDD [11109] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster24817 { label="MicroBatchScan"; 11089 [labelType="html" label="DataSourceRDD [11089] run at <unknown>:0"]; 11090 [labelType="html" label="MapPartitionsRDD [11090] run at <unknown>:0"]; } subgraph cluster24816 { label="Project"; 11091 [labelType="html" label="MapPartitionsRDD [11091] run at <unknown>:0"]; } subgraph cluster24812 { label="WholeStageCodegen (1)"; 11092 [labelType="html" label="MapPartitionsRDD [11092] run at <unknown>:0"]; } subgraph cluster24834 { label="WholeStageCodegen (1)"; 11100 [labelType="html" label="MapPartitionsRDD [11100] toJavaRDD at <unknown>:0"]; } subgraph cluster24833 { label="Filter"; 11101 [labelType="html" label="MapPartitionsRDD [11101] toJavaRDD at <unknown>:0"]; } subgraph cluster24832 { label="Project"; 11102 [labelType="html" label="MapPartitionsRDD [11102] toJavaRDD at <unknown>:0"]; } subgraph cluster24829 { label="WholeStageCodegen (2)"; 11103 [labelType="html" label="MapPartitionsRDD [11103] toJavaRDD at <unknown>:0"]; } subgraph cluster24828 { label="Project"; 11104 [labelType="html" label="MapPartitionsRDD [11104] toJavaRDD at <unknown>:0"]; } subgraph cluster24827 { label="DeserializeToObject"; 11105 [labelType="html" label="MapPartitionsRDD [11105] toJavaRDD at <unknown>:0"]; } subgraph cluster24826 { label="MapPartitions"; 11106 [labelType="html" label="MapPartitionsRDD [11106] toJavaRDD at <unknown>:0"]; } subgraph cluster24836 { label="mapPartitions"; 11108 [labelType="html" label="MapPartitionsRDD [11108] toJavaRDD at <unknown>:0"]; } } 11089->11090; 11090->11091; 11091->11092; 11092->11093; 11093->11100; 11100->11101; 11101->11102; 11102->11103; 11103->11104; 11104->11105; 11105->11106; 11106->11107; 11107->11108; 11108->11109; }

Event Timeline

Enable zooming