processing-stream-kafka-raw-to-minio - Details for Stage 438 (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: 438

digraph G { subgraph clusterstage_438 { label="Stage 438"; 4603 [labelType="html" label="SQLExecutionRDD [4603] run at <unknown>:0"]; 4611 [labelType="html" label="SQLExecutionRDD [4611] toJavaRDD at <unknown>:0"]; 4619 [labelType="html" label="PythonRDD [4619] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster10298 { label="MicroBatchScan"; 4599 [labelType="html" label="DataSourceRDD [4599] run at <unknown>:0"]; 4600 [labelType="html" label="MapPartitionsRDD [4600] run at <unknown>:0"]; } subgraph cluster10297 { label="Project"; 4601 [labelType="html" label="MapPartitionsRDD [4601] run at <unknown>:0"]; } subgraph cluster10293 { label="WholeStageCodegen (1)"; 4602 [labelType="html" label="MapPartitionsRDD [4602] run at <unknown>:0"]; } subgraph cluster10313 { label="WholeStageCodegen (1)"; 4604 [labelType="html" label="MapPartitionsRDD [4604] toJavaRDD at <unknown>:0"]; } subgraph cluster10312 { label="Filter"; 4605 [labelType="html" label="MapPartitionsRDD [4605] toJavaRDD at <unknown>:0"]; } subgraph cluster10311 { label="Project"; 4606 [labelType="html" label="MapPartitionsRDD [4606] toJavaRDD at <unknown>:0"]; } subgraph cluster10308 { label="WholeStageCodegen (2)"; 4607 [labelType="html" label="MapPartitionsRDD [4607] toJavaRDD at <unknown>:0"]; } subgraph cluster10307 { label="Project"; 4608 [labelType="html" label="MapPartitionsRDD [4608] toJavaRDD at <unknown>:0"]; } subgraph cluster10306 { label="DeserializeToObject"; 4609 [labelType="html" label="MapPartitionsRDD [4609] toJavaRDD at <unknown>:0"]; } subgraph cluster10305 { label="MapPartitions"; 4610 [labelType="html" label="MapPartitionsRDD [4610] toJavaRDD at <unknown>:0"]; } subgraph cluster10315 { label="mapPartitions"; 4612 [labelType="html" label="MapPartitionsRDD [4612] toJavaRDD at <unknown>:0"]; } } 4599->4600; 4600->4601; 4601->4602; 4602->4603; 4603->4604; 4604->4605; 4605->4606; 4606->4607; 4607->4608; 4608->4609; 4609->4610; 4610->4611; 4611->4612; 4612->4619; }

Event Timeline

Enable zooming