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

digraph G { subgraph clusterstage_23 { label="Stage 23"; 235 [labelType="html" label="SQLExecutionRDD [235] run at <unknown>:0"]; 249 [labelType="html" label="SQLExecutionRDD [249] toJavaRDD at NativeMethodAccessorImpl.java:0"]; 251 [labelType="html" label="PythonRDD [251] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster522 { label="MicroBatchScan"; 231 [labelType="html" label="DataSourceRDD [231] run at <unknown>:0"]; 232 [labelType="html" label="MapPartitionsRDD [232] run at <unknown>:0"]; } subgraph cluster521 { label="Project"; 233 [labelType="html" label="MapPartitionsRDD [233] run at <unknown>:0"]; } subgraph cluster517 { label="WholeStageCodegen (1)"; 234 [labelType="html" label="MapPartitionsRDD [234] run at <unknown>:0"]; } subgraph cluster539 { label="WholeStageCodegen (1)"; 242 [labelType="html" label="MapPartitionsRDD [242] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster538 { label="Filter"; 243 [labelType="html" label="MapPartitionsRDD [243] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster537 { label="Project"; 244 [labelType="html" label="MapPartitionsRDD [244] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster534 { label="WholeStageCodegen (2)"; 245 [labelType="html" label="MapPartitionsRDD [245] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster533 { label="Project"; 246 [labelType="html" label="MapPartitionsRDD [246] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster532 { label="DeserializeToObject"; 247 [labelType="html" label="MapPartitionsRDD [247] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster531 { label="MapPartitions"; 248 [labelType="html" label="MapPartitionsRDD [248] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster541 { label="mapPartitions"; 250 [labelType="html" label="MapPartitionsRDD [250] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } } 231->232; 232->233; 233->234; 234->235; 235->242; 242->243; 243->244; 244->245; 245->246; 246->247; 247->248; 248->249; 249->250; 250->251; }

Event Timeline

Enable zooming