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

digraph G { subgraph clusterstage_427 { label="Stage 427"; 4499 [labelType="html" label="SQLExecutionRDD [4499] run at <unknown>:0"]; 4507 [labelType="html" label="SQLExecutionRDD [4507] toJavaRDD at <unknown>:0"]; 4509 [labelType="html" label="PythonRDD [4509] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster10059 { label="MicroBatchScan"; 4495 [labelType="html" label="DataSourceRDD [4495] run at <unknown>:0"]; 4496 [labelType="html" label="MapPartitionsRDD [4496] run at <unknown>:0"]; } subgraph cluster10058 { label="Project"; 4497 [labelType="html" label="MapPartitionsRDD [4497] run at <unknown>:0"]; } subgraph cluster10054 { label="WholeStageCodegen (1)"; 4498 [labelType="html" label="MapPartitionsRDD [4498] run at <unknown>:0"]; } subgraph cluster10068 { label="WholeStageCodegen (1)"; 4500 [labelType="html" label="MapPartitionsRDD [4500] toJavaRDD at <unknown>:0"]; } subgraph cluster10067 { label="Filter"; 4501 [labelType="html" label="MapPartitionsRDD [4501] toJavaRDD at <unknown>:0"]; } subgraph cluster10066 { label="Project"; 4502 [labelType="html" label="MapPartitionsRDD [4502] toJavaRDD at <unknown>:0"]; } subgraph cluster10063 { label="WholeStageCodegen (2)"; 4503 [labelType="html" label="MapPartitionsRDD [4503] toJavaRDD at <unknown>:0"]; } subgraph cluster10062 { label="Project"; 4504 [labelType="html" label="MapPartitionsRDD [4504] toJavaRDD at <unknown>:0"]; } subgraph cluster10061 { label="DeserializeToObject"; 4505 [labelType="html" label="MapPartitionsRDD [4505] toJavaRDD at <unknown>:0"]; } subgraph cluster10060 { label="MapPartitions"; 4506 [labelType="html" label="MapPartitionsRDD [4506] toJavaRDD at <unknown>:0"]; } subgraph cluster10070 { label="mapPartitions"; 4508 [labelType="html" label="MapPartitionsRDD [4508] toJavaRDD at <unknown>:0"]; } } 4495->4496; 4496->4497; 4497->4498; 4498->4499; 4499->4500; 4500->4501; 4501->4502; 4502->4503; 4503->4504; 4504->4505; 4505->4506; 4506->4507; 4507->4508; 4508->4509; }

Event Timeline

Enable zooming