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

digraph G { subgraph clusterstage_435 { label="Stage 435"; 4583 [labelType="html" label="SQLExecutionRDD [4583] run at <unknown>:0"]; 4591 [labelType="html" label="SQLExecutionRDD [4591] toJavaRDD at <unknown>:0"]; 4593 [labelType="html" label="PythonRDD [4593] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster10247 { label="MicroBatchScan"; 4579 [labelType="html" label="DataSourceRDD [4579] run at <unknown>:0"]; 4580 [labelType="html" label="MapPartitionsRDD [4580] run at <unknown>:0"]; } subgraph cluster10246 { label="Project"; 4581 [labelType="html" label="MapPartitionsRDD [4581] run at <unknown>:0"]; } subgraph cluster10242 { label="WholeStageCodegen (1)"; 4582 [labelType="html" label="MapPartitionsRDD [4582] run at <unknown>:0"]; } subgraph cluster10256 { label="WholeStageCodegen (1)"; 4584 [labelType="html" label="MapPartitionsRDD [4584] toJavaRDD at <unknown>:0"]; } subgraph cluster10255 { label="Filter"; 4585 [labelType="html" label="MapPartitionsRDD [4585] toJavaRDD at <unknown>:0"]; } subgraph cluster10254 { label="Project"; 4586 [labelType="html" label="MapPartitionsRDD [4586] toJavaRDD at <unknown>:0"]; } subgraph cluster10251 { label="WholeStageCodegen (2)"; 4587 [labelType="html" label="MapPartitionsRDD [4587] toJavaRDD at <unknown>:0"]; } subgraph cluster10250 { label="Project"; 4588 [labelType="html" label="MapPartitionsRDD [4588] toJavaRDD at <unknown>:0"]; } subgraph cluster10249 { label="DeserializeToObject"; 4589 [labelType="html" label="MapPartitionsRDD [4589] toJavaRDD at <unknown>:0"]; } subgraph cluster10248 { label="MapPartitions"; 4590 [labelType="html" label="MapPartitionsRDD [4590] toJavaRDD at <unknown>:0"]; } subgraph cluster10258 { label="mapPartitions"; 4592 [labelType="html" label="MapPartitionsRDD [4592] toJavaRDD at <unknown>:0"]; } } 4579->4580; 4580->4581; 4581->4582; 4582->4583; 4583->4584; 4584->4585; 4585->4586; 4586->4587; 4587->4588; 4588->4589; 4589->4590; 4590->4591; 4591->4592; 4592->4593; }

Event Timeline

Enable zooming