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

digraph G { subgraph clusterstage_1068 { label="Stage 1068"; 11219 [labelType="html" label="SQLExecutionRDD [11219] run at <unknown>:0"]; 11233 [labelType="html" label="SQLExecutionRDD [11233] toJavaRDD at <unknown>:0"]; 11235 [labelType="html" label="PythonRDD [11235] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster25099 { label="MicroBatchScan"; 11215 [labelType="html" label="DataSourceRDD [11215] run at <unknown>:0"]; 11216 [labelType="html" label="MapPartitionsRDD [11216] run at <unknown>:0"]; } subgraph cluster25098 { label="Project"; 11217 [labelType="html" label="MapPartitionsRDD [11217] run at <unknown>:0"]; } subgraph cluster25094 { label="WholeStageCodegen (1)"; 11218 [labelType="html" label="MapPartitionsRDD [11218] run at <unknown>:0"]; } subgraph cluster25116 { label="WholeStageCodegen (1)"; 11226 [labelType="html" label="MapPartitionsRDD [11226] toJavaRDD at <unknown>:0"]; } subgraph cluster25115 { label="Filter"; 11227 [labelType="html" label="MapPartitionsRDD [11227] toJavaRDD at <unknown>:0"]; } subgraph cluster25114 { label="Project"; 11228 [labelType="html" label="MapPartitionsRDD [11228] toJavaRDD at <unknown>:0"]; } subgraph cluster25111 { label="WholeStageCodegen (2)"; 11229 [labelType="html" label="MapPartitionsRDD [11229] toJavaRDD at <unknown>:0"]; } subgraph cluster25110 { label="Project"; 11230 [labelType="html" label="MapPartitionsRDD [11230] toJavaRDD at <unknown>:0"]; } subgraph cluster25109 { label="DeserializeToObject"; 11231 [labelType="html" label="MapPartitionsRDD [11231] toJavaRDD at <unknown>:0"]; } subgraph cluster25108 { label="MapPartitions"; 11232 [labelType="html" label="MapPartitionsRDD [11232] toJavaRDD at <unknown>:0"]; } subgraph cluster25118 { label="mapPartitions"; 11234 [labelType="html" label="MapPartitionsRDD [11234] toJavaRDD at <unknown>:0"]; } } 11215->11216; 11216->11217; 11217->11218; 11218->11219; 11219->11226; 11226->11227; 11227->11228; 11228->11229; 11229->11230; 11230->11231; 11231->11232; 11232->11233; 11233->11234; 11234->11235; }

Event Timeline

Enable zooming