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

digraph G { subgraph clusterstage_1450 { label="Stage 1450"; 15236 [labelType="html" label="SQLExecutionRDD [15236] run at <unknown>:0"]; 15244 [labelType="html" label="SQLExecutionRDD [15244] toJavaRDD at <unknown>:0"]; 15246 [labelType="html" label="PythonRDD [15246] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster34084 { label="MicroBatchScan"; 15232 [labelType="html" label="DataSourceRDD [15232] run at <unknown>:0"]; 15233 [labelType="html" label="MapPartitionsRDD [15233] run at <unknown>:0"]; } subgraph cluster34083 { label="Project"; 15234 [labelType="html" label="MapPartitionsRDD [15234] run at <unknown>:0"]; } subgraph cluster34077 { label="WholeStageCodegen (1)"; 15235 [labelType="html" label="MapPartitionsRDD [15235] run at <unknown>:0"]; } subgraph cluster34093 { label="WholeStageCodegen (1)"; 15237 [labelType="html" label="MapPartitionsRDD [15237] toJavaRDD at <unknown>:0"]; } subgraph cluster34092 { label="Filter"; 15238 [labelType="html" label="MapPartitionsRDD [15238] toJavaRDD at <unknown>:0"]; } subgraph cluster34091 { label="Project"; 15239 [labelType="html" label="MapPartitionsRDD [15239] toJavaRDD at <unknown>:0"]; } subgraph cluster34088 { label="WholeStageCodegen (2)"; 15240 [labelType="html" label="MapPartitionsRDD [15240] toJavaRDD at <unknown>:0"]; } subgraph cluster34087 { label="Project"; 15241 [labelType="html" label="MapPartitionsRDD [15241] toJavaRDD at <unknown>:0"]; } subgraph cluster34086 { label="DeserializeToObject"; 15242 [labelType="html" label="MapPartitionsRDD [15242] toJavaRDD at <unknown>:0"]; } subgraph cluster34085 { label="MapPartitions"; 15243 [labelType="html" label="MapPartitionsRDD [15243] toJavaRDD at <unknown>:0"]; } subgraph cluster34095 { label="mapPartitions"; 15245 [labelType="html" label="MapPartitionsRDD [15245] toJavaRDD at <unknown>:0"]; } } 15232->15233; 15233->15234; 15234->15235; 15235->15236; 15236->15237; 15237->15238; 15238->15239; 15239->15240; 15240->15241; 15241->15242; 15242->15243; 15243->15244; 15244->15245; 15245->15246; }

Event Timeline

Enable zooming