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

digraph G { subgraph clusterstage_313 { label="Stage 313"; 3286 [labelType="html" label="SQLExecutionRDD [3286] run at <unknown>:0"]; 3294 [labelType="html" label="SQLExecutionRDD [3294] toJavaRDD at <unknown>:0"]; 3296 [labelType="html" label="PythonRDD [3296] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster7345 { label="MicroBatchScan"; 3282 [labelType="html" label="DataSourceRDD [3282] run at <unknown>:0"]; 3283 [labelType="html" label="MapPartitionsRDD [3283] run at <unknown>:0"]; } subgraph cluster7344 { label="Project"; 3284 [labelType="html" label="MapPartitionsRDD [3284] run at <unknown>:0"]; } subgraph cluster7340 { label="WholeStageCodegen (1)"; 3285 [labelType="html" label="MapPartitionsRDD [3285] run at <unknown>:0"]; } subgraph cluster7354 { label="WholeStageCodegen (1)"; 3287 [labelType="html" label="MapPartitionsRDD [3287] toJavaRDD at <unknown>:0"]; } subgraph cluster7353 { label="Filter"; 3288 [labelType="html" label="MapPartitionsRDD [3288] toJavaRDD at <unknown>:0"]; } subgraph cluster7352 { label="Project"; 3289 [labelType="html" label="MapPartitionsRDD [3289] toJavaRDD at <unknown>:0"]; } subgraph cluster7349 { label="WholeStageCodegen (2)"; 3290 [labelType="html" label="MapPartitionsRDD [3290] toJavaRDD at <unknown>:0"]; } subgraph cluster7348 { label="Project"; 3291 [labelType="html" label="MapPartitionsRDD [3291] toJavaRDD at <unknown>:0"]; } subgraph cluster7347 { label="DeserializeToObject"; 3292 [labelType="html" label="MapPartitionsRDD [3292] toJavaRDD at <unknown>:0"]; } subgraph cluster7346 { label="MapPartitions"; 3293 [labelType="html" label="MapPartitionsRDD [3293] toJavaRDD at <unknown>:0"]; } subgraph cluster7356 { label="mapPartitions"; 3295 [labelType="html" label="MapPartitionsRDD [3295] toJavaRDD at <unknown>:0"]; } } 3282->3283; 3283->3284; 3284->3285; 3285->3286; 3286->3287; 3287->3288; 3288->3289; 3289->3290; 3290->3291; 3291->3292; 3292->3293; 3293->3294; 3294->3295; 3295->3296; }

Event Timeline

Enable zooming