processing-stream-kafka-raw-to-minio - Details for Stage 1214 (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 / 484
Associated Job Ids: 1215

digraph G { subgraph clusterstage_1214 { label="Stage 1214"; 12752 [labelType="html" label="SQLExecutionRDD [12752] run at <unknown>:0"]; 12766 [labelType="html" label="SQLExecutionRDD [12766] toJavaRDD at <unknown>:0"]; 12768 [labelType="html" label="PythonRDD [12768] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster28530 { label="MicroBatchScan"; 12748 [labelType="html" label="DataSourceRDD [12748] run at <unknown>:0"]; 12749 [labelType="html" label="MapPartitionsRDD [12749] run at <unknown>:0"]; } subgraph cluster28529 { label="Project"; 12750 [labelType="html" label="MapPartitionsRDD [12750] run at <unknown>:0"]; } subgraph cluster28525 { label="WholeStageCodegen (1)"; 12751 [labelType="html" label="MapPartitionsRDD [12751] run at <unknown>:0"]; } subgraph cluster28547 { label="WholeStageCodegen (1)"; 12759 [labelType="html" label="MapPartitionsRDD [12759] toJavaRDD at <unknown>:0"]; } subgraph cluster28546 { label="Filter"; 12760 [labelType="html" label="MapPartitionsRDD [12760] toJavaRDD at <unknown>:0"]; } subgraph cluster28545 { label="Project"; 12761 [labelType="html" label="MapPartitionsRDD [12761] toJavaRDD at <unknown>:0"]; } subgraph cluster28542 { label="WholeStageCodegen (2)"; 12762 [labelType="html" label="MapPartitionsRDD [12762] toJavaRDD at <unknown>:0"]; } subgraph cluster28541 { label="Project"; 12763 [labelType="html" label="MapPartitionsRDD [12763] toJavaRDD at <unknown>:0"]; } subgraph cluster28540 { label="DeserializeToObject"; 12764 [labelType="html" label="MapPartitionsRDD [12764] toJavaRDD at <unknown>:0"]; } subgraph cluster28539 { label="MapPartitions"; 12765 [labelType="html" label="MapPartitionsRDD [12765] toJavaRDD at <unknown>:0"]; } subgraph cluster28549 { label="mapPartitions"; 12767 [labelType="html" label="MapPartitionsRDD [12767] toJavaRDD at <unknown>:0"]; } } 12748->12749; 12749->12750; 12750->12751; 12751->12752; 12752->12759; 12759->12760; 12760->12761; 12761->12762; 12762->12763; 12763->12764; 12764->12765; 12765->12766; 12766->12767; 12767->12768; }

Event Timeline

Enable zooming