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

digraph G { subgraph clusterstage_319 { label="Stage 319"; 3343 [labelType="html" label="SQLExecutionRDD [3343] run at <unknown>:0"]; 3357 [labelType="html" label="SQLExecutionRDD [3357] toJavaRDD at <unknown>:0"]; 3359 [labelType="html" label="PythonRDD [3359] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster7478 { label="MicroBatchScan"; 3339 [labelType="html" label="DataSourceRDD [3339] run at <unknown>:0"]; 3340 [labelType="html" label="MapPartitionsRDD [3340] run at <unknown>:0"]; } subgraph cluster7477 { label="Project"; 3341 [labelType="html" label="MapPartitionsRDD [3341] run at <unknown>:0"]; } subgraph cluster7473 { label="WholeStageCodegen (1)"; 3342 [labelType="html" label="MapPartitionsRDD [3342] run at <unknown>:0"]; } subgraph cluster7495 { label="WholeStageCodegen (1)"; 3350 [labelType="html" label="MapPartitionsRDD [3350] toJavaRDD at <unknown>:0"]; } subgraph cluster7494 { label="Filter"; 3351 [labelType="html" label="MapPartitionsRDD [3351] toJavaRDD at <unknown>:0"]; } subgraph cluster7493 { label="Project"; 3352 [labelType="html" label="MapPartitionsRDD [3352] toJavaRDD at <unknown>:0"]; } subgraph cluster7490 { label="WholeStageCodegen (2)"; 3353 [labelType="html" label="MapPartitionsRDD [3353] toJavaRDD at <unknown>:0"]; } subgraph cluster7489 { label="Project"; 3354 [labelType="html" label="MapPartitionsRDD [3354] toJavaRDD at <unknown>:0"]; } subgraph cluster7488 { label="DeserializeToObject"; 3355 [labelType="html" label="MapPartitionsRDD [3355] toJavaRDD at <unknown>:0"]; } subgraph cluster7487 { label="MapPartitions"; 3356 [labelType="html" label="MapPartitionsRDD [3356] toJavaRDD at <unknown>:0"]; } subgraph cluster7497 { label="mapPartitions"; 3358 [labelType="html" label="MapPartitionsRDD [3358] toJavaRDD at <unknown>:0"]; } } 3339->3340; 3340->3341; 3341->3342; 3342->3343; 3343->3350; 3350->3351; 3351->3352; 3352->3353; 3353->3354; 3354->3355; 3355->3356; 3356->3357; 3357->3358; 3358->3359; }

Event Timeline

Enable zooming