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

digraph G { subgraph clusterstage_224 { label="Stage 224"; 2356 [labelType="html" label="SQLExecutionRDD [2356] run at <unknown>:0"]; 2364 [labelType="html" label="SQLExecutionRDD [2364] toJavaRDD at <unknown>:0"]; 2366 [labelType="html" label="PythonRDD [2366] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster5269 { label="MicroBatchScan"; 2352 [labelType="html" label="DataSourceRDD [2352] run at <unknown>:0"]; 2353 [labelType="html" label="MapPartitionsRDD [2353] run at <unknown>:0"]; } subgraph cluster5268 { label="Project"; 2354 [labelType="html" label="MapPartitionsRDD [2354] run at <unknown>:0"]; } subgraph cluster5264 { label="WholeStageCodegen (1)"; 2355 [labelType="html" label="MapPartitionsRDD [2355] run at <unknown>:0"]; } subgraph cluster5278 { label="WholeStageCodegen (1)"; 2357 [labelType="html" label="MapPartitionsRDD [2357] toJavaRDD at <unknown>:0"]; } subgraph cluster5277 { label="Filter"; 2358 [labelType="html" label="MapPartitionsRDD [2358] toJavaRDD at <unknown>:0"]; } subgraph cluster5276 { label="Project"; 2359 [labelType="html" label="MapPartitionsRDD [2359] toJavaRDD at <unknown>:0"]; } subgraph cluster5273 { label="WholeStageCodegen (2)"; 2360 [labelType="html" label="MapPartitionsRDD [2360] toJavaRDD at <unknown>:0"]; } subgraph cluster5272 { label="Project"; 2361 [labelType="html" label="MapPartitionsRDD [2361] toJavaRDD at <unknown>:0"]; } subgraph cluster5271 { label="DeserializeToObject"; 2362 [labelType="html" label="MapPartitionsRDD [2362] toJavaRDD at <unknown>:0"]; } subgraph cluster5270 { label="MapPartitions"; 2363 [labelType="html" label="MapPartitionsRDD [2363] toJavaRDD at <unknown>:0"]; } subgraph cluster5280 { label="mapPartitions"; 2365 [labelType="html" label="MapPartitionsRDD [2365] toJavaRDD at <unknown>:0"]; } } 2352->2353; 2353->2354; 2354->2355; 2355->2356; 2356->2357; 2357->2358; 2358->2359; 2359->2360; 2360->2361; 2361->2362; 2362->2363; 2363->2364; 2364->2365; 2365->2366; }

Event Timeline

Enable zooming