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

digraph G { subgraph clusterstage_513 { label="Stage 513"; 5380 [labelType="html" label="SQLExecutionRDD [5380] run at <unknown>:0"]; 5394 [labelType="html" label="SQLExecutionRDD [5394] toJavaRDD at <unknown>:0"]; 5396 [labelType="html" label="PythonRDD [5396] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster12037 { label="MicroBatchScan"; 5376 [labelType="html" label="DataSourceRDD [5376] run at <unknown>:0"]; 5377 [labelType="html" label="MapPartitionsRDD [5377] run at <unknown>:0"]; } subgraph cluster12036 { label="Project"; 5378 [labelType="html" label="MapPartitionsRDD [5378] run at <unknown>:0"]; } subgraph cluster12032 { label="WholeStageCodegen (1)"; 5379 [labelType="html" label="MapPartitionsRDD [5379] run at <unknown>:0"]; } subgraph cluster12054 { label="WholeStageCodegen (1)"; 5387 [labelType="html" label="MapPartitionsRDD [5387] toJavaRDD at <unknown>:0"]; } subgraph cluster12053 { label="Filter"; 5388 [labelType="html" label="MapPartitionsRDD [5388] toJavaRDD at <unknown>:0"]; } subgraph cluster12052 { label="Project"; 5389 [labelType="html" label="MapPartitionsRDD [5389] toJavaRDD at <unknown>:0"]; } subgraph cluster12049 { label="WholeStageCodegen (2)"; 5390 [labelType="html" label="MapPartitionsRDD [5390] toJavaRDD at <unknown>:0"]; } subgraph cluster12048 { label="Project"; 5391 [labelType="html" label="MapPartitionsRDD [5391] toJavaRDD at <unknown>:0"]; } subgraph cluster12047 { label="DeserializeToObject"; 5392 [labelType="html" label="MapPartitionsRDD [5392] toJavaRDD at <unknown>:0"]; } subgraph cluster12046 { label="MapPartitions"; 5393 [labelType="html" label="MapPartitionsRDD [5393] toJavaRDD at <unknown>:0"]; } subgraph cluster12056 { label="mapPartitions"; 5395 [labelType="html" label="MapPartitionsRDD [5395] toJavaRDD at <unknown>:0"]; } } 5376->5377; 5377->5378; 5378->5379; 5379->5380; 5380->5387; 5387->5388; 5388->5389; 5389->5390; 5390->5391; 5391->5392; 5392->5393; 5393->5394; 5394->5395; 5395->5396; }

Event Timeline

Enable zooming