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

digraph G { subgraph clusterstage_20 { label="Stage 20"; 214 [labelType="html" label="SQLExecutionRDD [214] run at <unknown>:0"]; 222 [labelType="html" label="SQLExecutionRDD [222] toJavaRDD at NativeMethodAccessorImpl.java:0"]; 224 [labelType="html" label="PythonRDD [224] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster475 { label="MicroBatchScan"; 210 [labelType="html" label="DataSourceRDD [210] run at <unknown>:0"]; 211 [labelType="html" label="MapPartitionsRDD [211] run at <unknown>:0"]; } subgraph cluster474 { label="Project"; 212 [labelType="html" label="MapPartitionsRDD [212] run at <unknown>:0"]; } subgraph cluster470 { label="WholeStageCodegen (1)"; 213 [labelType="html" label="MapPartitionsRDD [213] run at <unknown>:0"]; } subgraph cluster484 { label="WholeStageCodegen (1)"; 215 [labelType="html" label="MapPartitionsRDD [215] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster483 { label="Filter"; 216 [labelType="html" label="MapPartitionsRDD [216] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster482 { label="Project"; 217 [labelType="html" label="MapPartitionsRDD [217] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster479 { label="WholeStageCodegen (2)"; 218 [labelType="html" label="MapPartitionsRDD [218] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster478 { label="Project"; 219 [labelType="html" label="MapPartitionsRDD [219] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster477 { label="DeserializeToObject"; 220 [labelType="html" label="MapPartitionsRDD [220] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster476 { label="MapPartitions"; 221 [labelType="html" label="MapPartitionsRDD [221] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster486 { label="mapPartitions"; 223 [labelType="html" label="MapPartitionsRDD [223] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } } 210->211; 211->212; 212->213; 213->214; 214->215; 215->216; 216->217; 217->218; 218->219; 219->220; 220->221; 221->222; 222->223; 223->224; }

Event Timeline

Enable zooming