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

digraph G { subgraph clusterstage_1437 { label="Stage 1437"; 15104 [labelType="html" label="SQLExecutionRDD [15104] run at <unknown>:0"]; 15112 [labelType="html" label="SQLExecutionRDD [15112] toJavaRDD at <unknown>:0"]; 15114 [labelType="html" label="PythonRDD [15114] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster33794 { label="MicroBatchScan"; 15100 [labelType="html" label="DataSourceRDD [15100] run at <unknown>:0"]; 15101 [labelType="html" label="MapPartitionsRDD [15101] run at <unknown>:0"]; } subgraph cluster33793 { label="Project"; 15102 [labelType="html" label="MapPartitionsRDD [15102] run at <unknown>:0"]; } subgraph cluster33789 { label="WholeStageCodegen (1)"; 15103 [labelType="html" label="MapPartitionsRDD [15103] run at <unknown>:0"]; } subgraph cluster33803 { label="WholeStageCodegen (1)"; 15105 [labelType="html" label="MapPartitionsRDD [15105] toJavaRDD at <unknown>:0"]; } subgraph cluster33802 { label="Filter"; 15106 [labelType="html" label="MapPartitionsRDD [15106] toJavaRDD at <unknown>:0"]; } subgraph cluster33801 { label="Project"; 15107 [labelType="html" label="MapPartitionsRDD [15107] toJavaRDD at <unknown>:0"]; } subgraph cluster33798 { label="WholeStageCodegen (2)"; 15108 [labelType="html" label="MapPartitionsRDD [15108] toJavaRDD at <unknown>:0"]; } subgraph cluster33797 { label="Project"; 15109 [labelType="html" label="MapPartitionsRDD [15109] toJavaRDD at <unknown>:0"]; } subgraph cluster33796 { label="DeserializeToObject"; 15110 [labelType="html" label="MapPartitionsRDD [15110] toJavaRDD at <unknown>:0"]; } subgraph cluster33795 { label="MapPartitions"; 15111 [labelType="html" label="MapPartitionsRDD [15111] toJavaRDD at <unknown>:0"]; } subgraph cluster33805 { label="mapPartitions"; 15113 [labelType="html" label="MapPartitionsRDD [15113] toJavaRDD at <unknown>:0"]; } } 15100->15101; 15101->15102; 15102->15103; 15103->15104; 15104->15105; 15105->15106; 15106->15107; 15107->15108; 15108->15109; 15109->15110; 15110->15111; 15111->15112; 15112->15113; 15113->15114; }

Event Timeline

Enable zooming