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

digraph G { subgraph clusterstage_2051 { label="Stage 2051"; 21551 [labelType="html" label="SQLExecutionRDD [21551] run at <unknown>:0"]; 21559 [labelType="html" label="SQLExecutionRDD [21559] toJavaRDD at <unknown>:0"]; 21561 [labelType="html" label="PythonRDD [21561] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster48223 { label="MicroBatchScan"; 21547 [labelType="html" label="DataSourceRDD [21547] run at <unknown>:0"]; 21548 [labelType="html" label="MapPartitionsRDD [21548] run at <unknown>:0"]; } subgraph cluster48222 { label="Project"; 21549 [labelType="html" label="MapPartitionsRDD [21549] run at <unknown>:0"]; } subgraph cluster48218 { label="WholeStageCodegen (1)"; 21550 [labelType="html" label="MapPartitionsRDD [21550] run at <unknown>:0"]; } subgraph cluster48232 { label="WholeStageCodegen (1)"; 21552 [labelType="html" label="MapPartitionsRDD [21552] toJavaRDD at <unknown>:0"]; } subgraph cluster48231 { label="Filter"; 21553 [labelType="html" label="MapPartitionsRDD [21553] toJavaRDD at <unknown>:0"]; } subgraph cluster48230 { label="Project"; 21554 [labelType="html" label="MapPartitionsRDD [21554] toJavaRDD at <unknown>:0"]; } subgraph cluster48227 { label="WholeStageCodegen (2)"; 21555 [labelType="html" label="MapPartitionsRDD [21555] toJavaRDD at <unknown>:0"]; } subgraph cluster48226 { label="Project"; 21556 [labelType="html" label="MapPartitionsRDD [21556] toJavaRDD at <unknown>:0"]; } subgraph cluster48225 { label="DeserializeToObject"; 21557 [labelType="html" label="MapPartitionsRDD [21557] toJavaRDD at <unknown>:0"]; } subgraph cluster48224 { label="MapPartitions"; 21558 [labelType="html" label="MapPartitionsRDD [21558] toJavaRDD at <unknown>:0"]; } subgraph cluster48234 { label="mapPartitions"; 21560 [labelType="html" label="MapPartitionsRDD [21560] toJavaRDD at <unknown>:0"]; } } 21547->21548; 21548->21549; 21549->21550; 21550->21551; 21551->21552; 21552->21553; 21553->21554; 21554->21555; 21555->21556; 21556->21557; 21557->21558; 21558->21559; 21559->21560; 21560->21561; }

Event Timeline

Enable zooming