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

digraph G { subgraph clusterstage_55 { label="Stage 55"; 571 [labelType="html" label="SQLExecutionRDD [571] run at <unknown>:0"]; 585 [labelType="html" label="SQLExecutionRDD [585] toJavaRDD at <unknown>:0"]; 587 [labelType="html" label="PythonRDD [587] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster1274 { label="MicroBatchScan"; 567 [labelType="html" label="DataSourceRDD [567] run at <unknown>:0"]; 568 [labelType="html" label="MapPartitionsRDD [568] run at <unknown>:0"]; } subgraph cluster1273 { label="Project"; 569 [labelType="html" label="MapPartitionsRDD [569] run at <unknown>:0"]; } subgraph cluster1269 { label="WholeStageCodegen (1)"; 570 [labelType="html" label="MapPartitionsRDD [570] run at <unknown>:0"]; } subgraph cluster1291 { label="WholeStageCodegen (1)"; 578 [labelType="html" label="MapPartitionsRDD [578] toJavaRDD at <unknown>:0"]; } subgraph cluster1290 { label="Filter"; 579 [labelType="html" label="MapPartitionsRDD [579] toJavaRDD at <unknown>:0"]; } subgraph cluster1289 { label="Project"; 580 [labelType="html" label="MapPartitionsRDD [580] toJavaRDD at <unknown>:0"]; } subgraph cluster1286 { label="WholeStageCodegen (2)"; 581 [labelType="html" label="MapPartitionsRDD [581] toJavaRDD at <unknown>:0"]; } subgraph cluster1285 { label="Project"; 582 [labelType="html" label="MapPartitionsRDD [582] toJavaRDD at <unknown>:0"]; } subgraph cluster1284 { label="DeserializeToObject"; 583 [labelType="html" label="MapPartitionsRDD [583] toJavaRDD at <unknown>:0"]; } subgraph cluster1283 { label="MapPartitions"; 584 [labelType="html" label="MapPartitionsRDD [584] toJavaRDD at <unknown>:0"]; } subgraph cluster1293 { label="mapPartitions"; 586 [labelType="html" label="MapPartitionsRDD [586] toJavaRDD at <unknown>:0"]; } } 567->568; 568->569; 569->570; 570->571; 571->578; 578->579; 579->580; 580->581; 581->582; 582->583; 583->584; 584->585; 585->586; 586->587; }

Event Timeline

Enable zooming