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

digraph G { subgraph clusterstage_441 { label="Stage 441"; 4646 [labelType="html" label="SQLExecutionRDD [4646] run at <unknown>:0"]; 4654 [labelType="html" label="SQLExecutionRDD [4654] toJavaRDD at <unknown>:0"]; 4656 [labelType="html" label="PythonRDD [4656] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster10388 { label="MicroBatchScan"; 4642 [labelType="html" label="DataSourceRDD [4642] run at <unknown>:0"]; 4643 [labelType="html" label="MapPartitionsRDD [4643] run at <unknown>:0"]; } subgraph cluster10387 { label="Project"; 4644 [labelType="html" label="MapPartitionsRDD [4644] run at <unknown>:0"]; } subgraph cluster10383 { label="WholeStageCodegen (1)"; 4645 [labelType="html" label="MapPartitionsRDD [4645] run at <unknown>:0"]; } subgraph cluster10397 { label="WholeStageCodegen (1)"; 4647 [labelType="html" label="MapPartitionsRDD [4647] toJavaRDD at <unknown>:0"]; } subgraph cluster10396 { label="Filter"; 4648 [labelType="html" label="MapPartitionsRDD [4648] toJavaRDD at <unknown>:0"]; } subgraph cluster10395 { label="Project"; 4649 [labelType="html" label="MapPartitionsRDD [4649] toJavaRDD at <unknown>:0"]; } subgraph cluster10392 { label="WholeStageCodegen (2)"; 4650 [labelType="html" label="MapPartitionsRDD [4650] toJavaRDD at <unknown>:0"]; } subgraph cluster10391 { label="Project"; 4651 [labelType="html" label="MapPartitionsRDD [4651] toJavaRDD at <unknown>:0"]; } subgraph cluster10390 { label="DeserializeToObject"; 4652 [labelType="html" label="MapPartitionsRDD [4652] toJavaRDD at <unknown>:0"]; } subgraph cluster10389 { label="MapPartitions"; 4653 [labelType="html" label="MapPartitionsRDD [4653] toJavaRDD at <unknown>:0"]; } subgraph cluster10399 { label="mapPartitions"; 4655 [labelType="html" label="MapPartitionsRDD [4655] toJavaRDD at <unknown>:0"]; } } 4642->4643; 4643->4644; 4644->4645; 4645->4646; 4646->4647; 4647->4648; 4648->4649; 4649->4650; 4650->4651; 4651->4652; 4652->4653; 4653->4654; 4654->4655; 4655->4656; }

Event Timeline

Enable zooming