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

digraph G { subgraph clusterstage_882 { label="Stage 882"; 9265 [labelType="html" label="SQLExecutionRDD [9265] run at <unknown>:0"]; 9273 [labelType="html" label="SQLExecutionRDD [9273] toJavaRDD at <unknown>:0"]; 9275 [labelType="html" label="PythonRDD [9275] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster20732 { label="MicroBatchScan"; 9261 [labelType="html" label="DataSourceRDD [9261] run at <unknown>:0"]; 9262 [labelType="html" label="MapPartitionsRDD [9262] run at <unknown>:0"]; } subgraph cluster20731 { label="Project"; 9263 [labelType="html" label="MapPartitionsRDD [9263] run at <unknown>:0"]; } subgraph cluster20727 { label="WholeStageCodegen (1)"; 9264 [labelType="html" label="MapPartitionsRDD [9264] run at <unknown>:0"]; } subgraph cluster20741 { label="WholeStageCodegen (1)"; 9266 [labelType="html" label="MapPartitionsRDD [9266] toJavaRDD at <unknown>:0"]; } subgraph cluster20740 { label="Filter"; 9267 [labelType="html" label="MapPartitionsRDD [9267] toJavaRDD at <unknown>:0"]; } subgraph cluster20739 { label="Project"; 9268 [labelType="html" label="MapPartitionsRDD [9268] toJavaRDD at <unknown>:0"]; } subgraph cluster20736 { label="WholeStageCodegen (2)"; 9269 [labelType="html" label="MapPartitionsRDD [9269] toJavaRDD at <unknown>:0"]; } subgraph cluster20735 { label="Project"; 9270 [labelType="html" label="MapPartitionsRDD [9270] toJavaRDD at <unknown>:0"]; } subgraph cluster20734 { label="DeserializeToObject"; 9271 [labelType="html" label="MapPartitionsRDD [9271] toJavaRDD at <unknown>:0"]; } subgraph cluster20733 { label="MapPartitions"; 9272 [labelType="html" label="MapPartitionsRDD [9272] toJavaRDD at <unknown>:0"]; } subgraph cluster20743 { label="mapPartitions"; 9274 [labelType="html" label="MapPartitionsRDD [9274] toJavaRDD at <unknown>:0"]; } } 9261->9262; 9262->9263; 9263->9264; 9264->9265; 9265->9266; 9266->9267; 9267->9268; 9268->9269; 9269->9270; 9270->9271; 9271->9272; 9272->9273; 9273->9274; 9274->9275; }

Event Timeline

Enable zooming