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

digraph G { subgraph clusterstage_37 { label="Stage 37"; 388 [labelType="html" label="SQLExecutionRDD [388] run at <unknown>:0"]; 396 [labelType="html" label="SQLExecutionRDD [396] toJavaRDD at <unknown>:0"]; 398 [labelType="html" label="PythonRDD [398] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster859 { label="MicroBatchScan"; 384 [labelType="html" label="DataSourceRDD [384] run at <unknown>:0"]; 385 [labelType="html" label="MapPartitionsRDD [385] run at <unknown>:0"]; } subgraph cluster858 { label="Project"; 386 [labelType="html" label="MapPartitionsRDD [386] run at <unknown>:0"]; } subgraph cluster854 { label="WholeStageCodegen (1)"; 387 [labelType="html" label="MapPartitionsRDD [387] run at <unknown>:0"]; } subgraph cluster868 { label="WholeStageCodegen (1)"; 389 [labelType="html" label="MapPartitionsRDD [389] toJavaRDD at <unknown>:0"]; } subgraph cluster867 { label="Filter"; 390 [labelType="html" label="MapPartitionsRDD [390] toJavaRDD at <unknown>:0"]; } subgraph cluster866 { label="Project"; 391 [labelType="html" label="MapPartitionsRDD [391] toJavaRDD at <unknown>:0"]; } subgraph cluster863 { label="WholeStageCodegen (2)"; 392 [labelType="html" label="MapPartitionsRDD [392] toJavaRDD at <unknown>:0"]; } subgraph cluster862 { label="Project"; 393 [labelType="html" label="MapPartitionsRDD [393] toJavaRDD at <unknown>:0"]; } subgraph cluster861 { label="DeserializeToObject"; 394 [labelType="html" label="MapPartitionsRDD [394] toJavaRDD at <unknown>:0"]; } subgraph cluster860 { label="MapPartitions"; 395 [labelType="html" label="MapPartitionsRDD [395] toJavaRDD at <unknown>:0"]; } subgraph cluster870 { label="mapPartitions"; 397 [labelType="html" label="MapPartitionsRDD [397] toJavaRDD at <unknown>:0"]; } } 384->385; 385->386; 386->387; 387->388; 388->389; 389->390; 390->391; 391->392; 392->393; 393->394; 394->395; 395->396; 396->397; 397->398; }

Event Timeline

Enable zooming