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

digraph G { subgraph clusterstage_1071 { label="Stage 1071"; 11261 [labelType="html" label="SQLExecutionRDD [11261] run at <unknown>:0"]; 11269 [labelType="html" label="SQLExecutionRDD [11269] toJavaRDD at <unknown>:0"]; 11271 [labelType="html" label="PythonRDD [11271] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster25193 { label="MicroBatchScan"; 11257 [labelType="html" label="DataSourceRDD [11257] run at <unknown>:0"]; 11258 [labelType="html" label="MapPartitionsRDD [11258] run at <unknown>:0"]; } subgraph cluster25192 { label="Project"; 11259 [labelType="html" label="MapPartitionsRDD [11259] run at <unknown>:0"]; } subgraph cluster25188 { label="WholeStageCodegen (1)"; 11260 [labelType="html" label="MapPartitionsRDD [11260] run at <unknown>:0"]; } subgraph cluster25202 { label="WholeStageCodegen (1)"; 11262 [labelType="html" label="MapPartitionsRDD [11262] toJavaRDD at <unknown>:0"]; } subgraph cluster25201 { label="Filter"; 11263 [labelType="html" label="MapPartitionsRDD [11263] toJavaRDD at <unknown>:0"]; } subgraph cluster25200 { label="Project"; 11264 [labelType="html" label="MapPartitionsRDD [11264] toJavaRDD at <unknown>:0"]; } subgraph cluster25197 { label="WholeStageCodegen (2)"; 11265 [labelType="html" label="MapPartitionsRDD [11265] toJavaRDD at <unknown>:0"]; } subgraph cluster25196 { label="Project"; 11266 [labelType="html" label="MapPartitionsRDD [11266] toJavaRDD at <unknown>:0"]; } subgraph cluster25195 { label="DeserializeToObject"; 11267 [labelType="html" label="MapPartitionsRDD [11267] toJavaRDD at <unknown>:0"]; } subgraph cluster25194 { label="MapPartitions"; 11268 [labelType="html" label="MapPartitionsRDD [11268] toJavaRDD at <unknown>:0"]; } subgraph cluster25204 { label="mapPartitions"; 11270 [labelType="html" label="MapPartitionsRDD [11270] toJavaRDD at <unknown>:0"]; } } 11257->11258; 11258->11259; 11259->11260; 11260->11261; 11261->11262; 11262->11263; 11263->11264; 11264->11265; 11265->11266; 11266->11267; 11267->11268; 11268->11269; 11269->11270; 11270->11271; }

Event Timeline

Enable zooming