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

digraph G { subgraph clusterstage_1452 { label="Stage 1452"; 15250 [labelType="html" label="SQLExecutionRDD [15250] run at <unknown>:0"]; 15258 [labelType="html" label="SQLExecutionRDD [15258] toJavaRDD at <unknown>:0"]; 15260 [labelType="html" label="PythonRDD [15260] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster34127 { label="MicroBatchScan"; 15246 [labelType="html" label="DataSourceRDD [15246] run at <unknown>:0"]; 15247 [labelType="html" label="MapPartitionsRDD [15247] run at <unknown>:0"]; } subgraph cluster34126 { label="Project"; 15248 [labelType="html" label="MapPartitionsRDD [15248] run at <unknown>:0"]; } subgraph cluster34122 { label="WholeStageCodegen (1)"; 15249 [labelType="html" label="MapPartitionsRDD [15249] run at <unknown>:0"]; } subgraph cluster34136 { label="WholeStageCodegen (1)"; 15251 [labelType="html" label="MapPartitionsRDD [15251] toJavaRDD at <unknown>:0"]; } subgraph cluster34135 { label="Filter"; 15252 [labelType="html" label="MapPartitionsRDD [15252] toJavaRDD at <unknown>:0"]; } subgraph cluster34134 { label="Project"; 15253 [labelType="html" label="MapPartitionsRDD [15253] toJavaRDD at <unknown>:0"]; } subgraph cluster34131 { label="WholeStageCodegen (2)"; 15254 [labelType="html" label="MapPartitionsRDD [15254] toJavaRDD at <unknown>:0"]; } subgraph cluster34130 { label="Project"; 15255 [labelType="html" label="MapPartitionsRDD [15255] toJavaRDD at <unknown>:0"]; } subgraph cluster34129 { label="DeserializeToObject"; 15256 [labelType="html" label="MapPartitionsRDD [15256] toJavaRDD at <unknown>:0"]; } subgraph cluster34128 { label="MapPartitions"; 15257 [labelType="html" label="MapPartitionsRDD [15257] toJavaRDD at <unknown>:0"]; } subgraph cluster34138 { label="mapPartitions"; 15259 [labelType="html" label="MapPartitionsRDD [15259] toJavaRDD at <unknown>:0"]; } } 15246->15247; 15247->15248; 15248->15249; 15249->15250; 15250->15251; 15251->15252; 15252->15253; 15253->15254; 15254->15255; 15255->15256; 15256->15257; 15257->15258; 15258->15259; 15259->15260; }

Event Timeline

Enable zooming