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

digraph G { subgraph clusterstage_454 { label="Stage 454"; 4772 [labelType="html" label="SQLExecutionRDD [4772] run at <unknown>:0"]; 4786 [labelType="html" label="SQLExecutionRDD [4786] toJavaRDD at <unknown>:0"]; 4788 [labelType="html" label="PythonRDD [4788] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster10670 { label="MicroBatchScan"; 4768 [labelType="html" label="DataSourceRDD [4768] run at <unknown>:0"]; 4769 [labelType="html" label="MapPartitionsRDD [4769] run at <unknown>:0"]; } subgraph cluster10669 { label="Project"; 4770 [labelType="html" label="MapPartitionsRDD [4770] run at <unknown>:0"]; } subgraph cluster10665 { label="WholeStageCodegen (1)"; 4771 [labelType="html" label="MapPartitionsRDD [4771] run at <unknown>:0"]; } subgraph cluster10687 { label="WholeStageCodegen (1)"; 4779 [labelType="html" label="MapPartitionsRDD [4779] toJavaRDD at <unknown>:0"]; } subgraph cluster10686 { label="Filter"; 4780 [labelType="html" label="MapPartitionsRDD [4780] toJavaRDD at <unknown>:0"]; } subgraph cluster10685 { label="Project"; 4781 [labelType="html" label="MapPartitionsRDD [4781] toJavaRDD at <unknown>:0"]; } subgraph cluster10682 { label="WholeStageCodegen (2)"; 4782 [labelType="html" label="MapPartitionsRDD [4782] toJavaRDD at <unknown>:0"]; } subgraph cluster10681 { label="Project"; 4783 [labelType="html" label="MapPartitionsRDD [4783] toJavaRDD at <unknown>:0"]; } subgraph cluster10680 { label="DeserializeToObject"; 4784 [labelType="html" label="MapPartitionsRDD [4784] toJavaRDD at <unknown>:0"]; } subgraph cluster10679 { label="MapPartitions"; 4785 [labelType="html" label="MapPartitionsRDD [4785] toJavaRDD at <unknown>:0"]; } subgraph cluster10689 { label="mapPartitions"; 4787 [labelType="html" label="MapPartitionsRDD [4787] toJavaRDD at <unknown>:0"]; } } 4768->4769; 4769->4770; 4770->4771; 4771->4772; 4772->4779; 4779->4780; 4780->4781; 4781->4782; 4782->4783; 4783->4784; 4784->4785; 4785->4786; 4786->4787; 4787->4788; }

Event Timeline

Enable zooming