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

digraph G { subgraph clusterstage_510 { label="Stage 510"; 5359 [labelType="html" label="SQLExecutionRDD [5359] run at <unknown>:0"]; 5367 [labelType="html" label="SQLExecutionRDD [5367] toJavaRDD at <unknown>:0"]; 5369 [labelType="html" label="PythonRDD [5369] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster11990 { label="MicroBatchScan"; 5355 [labelType="html" label="DataSourceRDD [5355] run at <unknown>:0"]; 5356 [labelType="html" label="MapPartitionsRDD [5356] run at <unknown>:0"]; } subgraph cluster11989 { label="Project"; 5357 [labelType="html" label="MapPartitionsRDD [5357] run at <unknown>:0"]; } subgraph cluster11985 { label="WholeStageCodegen (1)"; 5358 [labelType="html" label="MapPartitionsRDD [5358] run at <unknown>:0"]; } subgraph cluster11999 { label="WholeStageCodegen (1)"; 5360 [labelType="html" label="MapPartitionsRDD [5360] toJavaRDD at <unknown>:0"]; } subgraph cluster11998 { label="Filter"; 5361 [labelType="html" label="MapPartitionsRDD [5361] toJavaRDD at <unknown>:0"]; } subgraph cluster11997 { label="Project"; 5362 [labelType="html" label="MapPartitionsRDD [5362] toJavaRDD at <unknown>:0"]; } subgraph cluster11994 { label="WholeStageCodegen (2)"; 5363 [labelType="html" label="MapPartitionsRDD [5363] toJavaRDD at <unknown>:0"]; } subgraph cluster11993 { label="Project"; 5364 [labelType="html" label="MapPartitionsRDD [5364] toJavaRDD at <unknown>:0"]; } subgraph cluster11992 { label="DeserializeToObject"; 5365 [labelType="html" label="MapPartitionsRDD [5365] toJavaRDD at <unknown>:0"]; } subgraph cluster11991 { label="MapPartitions"; 5366 [labelType="html" label="MapPartitionsRDD [5366] toJavaRDD at <unknown>:0"]; } subgraph cluster12001 { label="mapPartitions"; 5368 [labelType="html" label="MapPartitionsRDD [5368] toJavaRDD at <unknown>:0"]; } } 5355->5356; 5356->5357; 5357->5358; 5358->5359; 5359->5360; 5360->5361; 5361->5362; 5362->5363; 5363->5364; 5364->5365; 5365->5366; 5366->5367; 5367->5368; 5368->5369; }

Event Timeline

Enable zooming