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

digraph G { subgraph clusterstage_200 { label="Stage 200"; 2104 [labelType="html" label="SQLExecutionRDD [2104] run at <unknown>:0"]; 2112 [labelType="html" label="SQLExecutionRDD [2112] toJavaRDD at <unknown>:0"]; 2114 [labelType="html" label="PythonRDD [2114] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster4705 { label="MicroBatchScan"; 2100 [labelType="html" label="DataSourceRDD [2100] run at <unknown>:0"]; 2101 [labelType="html" label="MapPartitionsRDD [2101] run at <unknown>:0"]; } subgraph cluster4704 { label="Project"; 2102 [labelType="html" label="MapPartitionsRDD [2102] run at <unknown>:0"]; } subgraph cluster4700 { label="WholeStageCodegen (1)"; 2103 [labelType="html" label="MapPartitionsRDD [2103] run at <unknown>:0"]; } subgraph cluster4714 { label="WholeStageCodegen (1)"; 2105 [labelType="html" label="MapPartitionsRDD [2105] toJavaRDD at <unknown>:0"]; } subgraph cluster4713 { label="Filter"; 2106 [labelType="html" label="MapPartitionsRDD [2106] toJavaRDD at <unknown>:0"]; } subgraph cluster4712 { label="Project"; 2107 [labelType="html" label="MapPartitionsRDD [2107] toJavaRDD at <unknown>:0"]; } subgraph cluster4709 { label="WholeStageCodegen (2)"; 2108 [labelType="html" label="MapPartitionsRDD [2108] toJavaRDD at <unknown>:0"]; } subgraph cluster4708 { label="Project"; 2109 [labelType="html" label="MapPartitionsRDD [2109] toJavaRDD at <unknown>:0"]; } subgraph cluster4707 { label="DeserializeToObject"; 2110 [labelType="html" label="MapPartitionsRDD [2110] toJavaRDD at <unknown>:0"]; } subgraph cluster4706 { label="MapPartitions"; 2111 [labelType="html" label="MapPartitionsRDD [2111] toJavaRDD at <unknown>:0"]; } subgraph cluster4716 { label="mapPartitions"; 2113 [labelType="html" label="MapPartitionsRDD [2113] toJavaRDD at <unknown>:0"]; } } 2100->2101; 2101->2102; 2102->2103; 2103->2104; 2104->2105; 2105->2106; 2106->2107; 2107->2108; 2108->2109; 2109->2110; 2110->2111; 2111->2112; 2112->2113; 2113->2114; }

Event Timeline

Enable zooming