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

digraph G { subgraph clusterstage_1628 { label="Stage 1628"; 17099 [labelType="html" label="SQLExecutionRDD [17099] run at <unknown>:0"]; 17113 [labelType="html" label="SQLExecutionRDD [17113] toJavaRDD at <unknown>:0"]; 17115 [labelType="html" label="PythonRDD [17115] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster38259 { label="MicroBatchScan"; 17095 [labelType="html" label="DataSourceRDD [17095] run at <unknown>:0"]; 17096 [labelType="html" label="MapPartitionsRDD [17096] run at <unknown>:0"]; } subgraph cluster38258 { label="Project"; 17097 [labelType="html" label="MapPartitionsRDD [17097] run at <unknown>:0"]; } subgraph cluster38254 { label="WholeStageCodegen (1)"; 17098 [labelType="html" label="MapPartitionsRDD [17098] run at <unknown>:0"]; } subgraph cluster38276 { label="WholeStageCodegen (1)"; 17106 [labelType="html" label="MapPartitionsRDD [17106] toJavaRDD at <unknown>:0"]; } subgraph cluster38275 { label="Filter"; 17107 [labelType="html" label="MapPartitionsRDD [17107] toJavaRDD at <unknown>:0"]; } subgraph cluster38274 { label="Project"; 17108 [labelType="html" label="MapPartitionsRDD [17108] toJavaRDD at <unknown>:0"]; } subgraph cluster38271 { label="WholeStageCodegen (2)"; 17109 [labelType="html" label="MapPartitionsRDD [17109] toJavaRDD at <unknown>:0"]; } subgraph cluster38270 { label="Project"; 17110 [labelType="html" label="MapPartitionsRDD [17110] toJavaRDD at <unknown>:0"]; } subgraph cluster38269 { label="DeserializeToObject"; 17111 [labelType="html" label="MapPartitionsRDD [17111] toJavaRDD at <unknown>:0"]; } subgraph cluster38268 { label="MapPartitions"; 17112 [labelType="html" label="MapPartitionsRDD [17112] toJavaRDD at <unknown>:0"]; } subgraph cluster38278 { label="mapPartitions"; 17114 [labelType="html" label="MapPartitionsRDD [17114] toJavaRDD at <unknown>:0"]; } } 17095->17096; 17096->17097; 17097->17098; 17098->17099; 17099->17106; 17106->17107; 17107->17108; 17108->17109; 17109->17110; 17110->17111; 17111->17112; 17112->17113; 17113->17114; 17114->17115; }

Event Timeline

Enable zooming