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

digraph G { subgraph clusterstage_690 { label="Stage 690"; 7249 [labelType="html" label="SQLExecutionRDD [7249] run at <unknown>:0"]; 7257 [labelType="html" label="SQLExecutionRDD [7257] toJavaRDD at <unknown>:0"]; 7259 [labelType="html" label="PythonRDD [7259] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster16220 { label="MicroBatchScan"; 7245 [labelType="html" label="DataSourceRDD [7245] run at <unknown>:0"]; 7246 [labelType="html" label="MapPartitionsRDD [7246] run at <unknown>:0"]; } subgraph cluster16219 { label="Project"; 7247 [labelType="html" label="MapPartitionsRDD [7247] run at <unknown>:0"]; } subgraph cluster16215 { label="WholeStageCodegen (1)"; 7248 [labelType="html" label="MapPartitionsRDD [7248] run at <unknown>:0"]; } subgraph cluster16229 { label="WholeStageCodegen (1)"; 7250 [labelType="html" label="MapPartitionsRDD [7250] toJavaRDD at <unknown>:0"]; } subgraph cluster16228 { label="Filter"; 7251 [labelType="html" label="MapPartitionsRDD [7251] toJavaRDD at <unknown>:0"]; } subgraph cluster16227 { label="Project"; 7252 [labelType="html" label="MapPartitionsRDD [7252] toJavaRDD at <unknown>:0"]; } subgraph cluster16224 { label="WholeStageCodegen (2)"; 7253 [labelType="html" label="MapPartitionsRDD [7253] toJavaRDD at <unknown>:0"]; } subgraph cluster16223 { label="Project"; 7254 [labelType="html" label="MapPartitionsRDD [7254] toJavaRDD at <unknown>:0"]; } subgraph cluster16222 { label="DeserializeToObject"; 7255 [labelType="html" label="MapPartitionsRDD [7255] toJavaRDD at <unknown>:0"]; } subgraph cluster16221 { label="MapPartitions"; 7256 [labelType="html" label="MapPartitionsRDD [7256] toJavaRDD at <unknown>:0"]; } subgraph cluster16231 { label="mapPartitions"; 7258 [labelType="html" label="MapPartitionsRDD [7258] toJavaRDD at <unknown>:0"]; } } 7245->7246; 7246->7247; 7247->7248; 7248->7249; 7249->7250; 7250->7251; 7251->7252; 7252->7253; 7253->7254; 7254->7255; 7255->7256; 7256->7257; 7257->7258; 7258->7259; }

Event Timeline

Enable zooming