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

digraph G { subgraph clusterstage_238 { label="Stage 238"; 2503 [labelType="html" label="SQLExecutionRDD [2503] run at <unknown>:0"]; 2511 [labelType="html" label="SQLExecutionRDD [2511] toJavaRDD at <unknown>:0"]; 2513 [labelType="html" label="PythonRDD [2513] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster5598 { label="MicroBatchScan"; 2499 [labelType="html" label="DataSourceRDD [2499] run at <unknown>:0"]; 2500 [labelType="html" label="MapPartitionsRDD [2500] run at <unknown>:0"]; } subgraph cluster5597 { label="Project"; 2501 [labelType="html" label="MapPartitionsRDD [2501] run at <unknown>:0"]; } subgraph cluster5593 { label="WholeStageCodegen (1)"; 2502 [labelType="html" label="MapPartitionsRDD [2502] run at <unknown>:0"]; } subgraph cluster5607 { label="WholeStageCodegen (1)"; 2504 [labelType="html" label="MapPartitionsRDD [2504] toJavaRDD at <unknown>:0"]; } subgraph cluster5606 { label="Filter"; 2505 [labelType="html" label="MapPartitionsRDD [2505] toJavaRDD at <unknown>:0"]; } subgraph cluster5605 { label="Project"; 2506 [labelType="html" label="MapPartitionsRDD [2506] toJavaRDD at <unknown>:0"]; } subgraph cluster5602 { label="WholeStageCodegen (2)"; 2507 [labelType="html" label="MapPartitionsRDD [2507] toJavaRDD at <unknown>:0"]; } subgraph cluster5601 { label="Project"; 2508 [labelType="html" label="MapPartitionsRDD [2508] toJavaRDD at <unknown>:0"]; } subgraph cluster5600 { label="DeserializeToObject"; 2509 [labelType="html" label="MapPartitionsRDD [2509] toJavaRDD at <unknown>:0"]; } subgraph cluster5599 { label="MapPartitions"; 2510 [labelType="html" label="MapPartitionsRDD [2510] toJavaRDD at <unknown>:0"]; } subgraph cluster5609 { label="mapPartitions"; 2512 [labelType="html" label="MapPartitionsRDD [2512] toJavaRDD at <unknown>:0"]; } } 2499->2500; 2500->2501; 2501->2502; 2502->2503; 2503->2504; 2504->2505; 2505->2506; 2506->2507; 2507->2508; 2508->2509; 2509->2510; 2510->2511; 2511->2512; 2512->2513; }

Event Timeline

Enable zooming