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

digraph G { subgraph clusterstage_52 { label="Stage 52"; 550 [labelType="html" label="SQLExecutionRDD [550] run at <unknown>:0"]; 558 [labelType="html" label="SQLExecutionRDD [558] toJavaRDD at <unknown>:0"]; 560 [labelType="html" label="PythonRDD [560] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster1227 { label="MicroBatchScan"; 546 [labelType="html" label="DataSourceRDD [546] run at <unknown>:0"]; 547 [labelType="html" label="MapPartitionsRDD [547] run at <unknown>:0"]; } subgraph cluster1226 { label="Project"; 548 [labelType="html" label="MapPartitionsRDD [548] run at <unknown>:0"]; } subgraph cluster1222 { label="WholeStageCodegen (1)"; 549 [labelType="html" label="MapPartitionsRDD [549] run at <unknown>:0"]; } subgraph cluster1236 { label="WholeStageCodegen (1)"; 551 [labelType="html" label="MapPartitionsRDD [551] toJavaRDD at <unknown>:0"]; } subgraph cluster1235 { label="Filter"; 552 [labelType="html" label="MapPartitionsRDD [552] toJavaRDD at <unknown>:0"]; } subgraph cluster1234 { label="Project"; 553 [labelType="html" label="MapPartitionsRDD [553] toJavaRDD at <unknown>:0"]; } subgraph cluster1231 { label="WholeStageCodegen (2)"; 554 [labelType="html" label="MapPartitionsRDD [554] toJavaRDD at <unknown>:0"]; } subgraph cluster1230 { label="Project"; 555 [labelType="html" label="MapPartitionsRDD [555] toJavaRDD at <unknown>:0"]; } subgraph cluster1229 { label="DeserializeToObject"; 556 [labelType="html" label="MapPartitionsRDD [556] toJavaRDD at <unknown>:0"]; } subgraph cluster1228 { label="MapPartitions"; 557 [labelType="html" label="MapPartitionsRDD [557] toJavaRDD at <unknown>:0"]; } subgraph cluster1244 { label="mapPartitions"; 559 [labelType="html" label="MapPartitionsRDD [559] toJavaRDD at <unknown>:0"]; } } 546->547; 547->548; 548->549; 549->550; 550->551; 551->552; 552->553; 553->554; 554->555; 555->556; 556->557; 557->558; 558->559; 559->560; }

Event Timeline

Enable zooming