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

digraph G { subgraph clusterstage_594 { label="Stage 594"; 6241 [labelType="html" label="SQLExecutionRDD [6241] run at <unknown>:0"]; 6249 [labelType="html" label="SQLExecutionRDD [6249] toJavaRDD at <unknown>:0"]; 6251 [labelType="html" label="PythonRDD [6251] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster13964 { label="MicroBatchScan"; 6237 [labelType="html" label="DataSourceRDD [6237] run at <unknown>:0"]; 6238 [labelType="html" label="MapPartitionsRDD [6238] run at <unknown>:0"]; } subgraph cluster13963 { label="Project"; 6239 [labelType="html" label="MapPartitionsRDD [6239] run at <unknown>:0"]; } subgraph cluster13959 { label="WholeStageCodegen (1)"; 6240 [labelType="html" label="MapPartitionsRDD [6240] run at <unknown>:0"]; } subgraph cluster13973 { label="WholeStageCodegen (1)"; 6242 [labelType="html" label="MapPartitionsRDD [6242] toJavaRDD at <unknown>:0"]; } subgraph cluster13972 { label="Filter"; 6243 [labelType="html" label="MapPartitionsRDD [6243] toJavaRDD at <unknown>:0"]; } subgraph cluster13971 { label="Project"; 6244 [labelType="html" label="MapPartitionsRDD [6244] toJavaRDD at <unknown>:0"]; } subgraph cluster13968 { label="WholeStageCodegen (2)"; 6245 [labelType="html" label="MapPartitionsRDD [6245] toJavaRDD at <unknown>:0"]; } subgraph cluster13967 { label="Project"; 6246 [labelType="html" label="MapPartitionsRDD [6246] toJavaRDD at <unknown>:0"]; } subgraph cluster13966 { label="DeserializeToObject"; 6247 [labelType="html" label="MapPartitionsRDD [6247] toJavaRDD at <unknown>:0"]; } subgraph cluster13965 { label="MapPartitions"; 6248 [labelType="html" label="MapPartitionsRDD [6248] toJavaRDD at <unknown>:0"]; } subgraph cluster13975 { label="mapPartitions"; 6250 [labelType="html" label="MapPartitionsRDD [6250] toJavaRDD at <unknown>:0"]; } } 6237->6238; 6238->6239; 6239->6240; 6240->6241; 6241->6242; 6242->6243; 6243->6244; 6244->6245; 6245->6246; 6246->6247; 6247->6248; 6248->6249; 6249->6250; 6250->6251; }

Event Timeline

Enable zooming