processing-stream-kafka-raw-to-minio - Details for Stage 25 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 3 s
Locality Level Summary: Process local: 4
Input Size / Records: 0.0 B / 409
Associated Job Ids: 25

digraph G { subgraph clusterstage_25 { label="Stage 25"; 262 [labelType="html" label="SQLExecutionRDD [262] run at <unknown>:0"]; 270 [labelType="html" label="SQLExecutionRDD [270] toJavaRDD at NativeMethodAccessorImpl.java:0"]; 272 [labelType="html" label="PythonRDD [272] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster577 { label="MicroBatchScan"; 258 [labelType="html" label="DataSourceRDD [258] run at <unknown>:0"]; 259 [labelType="html" label="MapPartitionsRDD [259] run at <unknown>:0"]; } subgraph cluster576 { label="Project"; 260 [labelType="html" label="MapPartitionsRDD [260] run at <unknown>:0"]; } subgraph cluster572 { label="WholeStageCodegen (1)"; 261 [labelType="html" label="MapPartitionsRDD [261] run at <unknown>:0"]; } subgraph cluster586 { label="WholeStageCodegen (1)"; 263 [labelType="html" label="MapPartitionsRDD [263] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster585 { label="Filter"; 264 [labelType="html" label="MapPartitionsRDD [264] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster584 { label="Project"; 265 [labelType="html" label="MapPartitionsRDD [265] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster581 { label="WholeStageCodegen (2)"; 266 [labelType="html" label="MapPartitionsRDD [266] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster580 { label="Project"; 267 [labelType="html" label="MapPartitionsRDD [267] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster579 { label="DeserializeToObject"; 268 [labelType="html" label="MapPartitionsRDD [268] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster578 { label="MapPartitions"; 269 [labelType="html" label="MapPartitionsRDD [269] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster588 { label="mapPartitions"; 271 [labelType="html" label="MapPartitionsRDD [271] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } } 258->259; 259->260; 260->261; 261->262; 262->263; 263->264; 264->265; 265->266; 266->267; 267->268; 268->269; 269->270; 270->271; 271->272; }

Event Timeline

Enable zooming