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

digraph G { subgraph clusterstage_543 { label="Stage 543"; 5701 [labelType="html" label="SQLExecutionRDD [5701] run at <unknown>:0"]; 5709 [labelType="html" label="SQLExecutionRDD [5709] toJavaRDD at <unknown>:0"]; 5711 [labelType="html" label="PythonRDD [5711] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster12750 { label="MicroBatchScan"; 5697 [labelType="html" label="DataSourceRDD [5697] run at <unknown>:0"]; 5698 [labelType="html" label="MapPartitionsRDD [5698] run at <unknown>:0"]; } subgraph cluster12749 { label="Project"; 5699 [labelType="html" label="MapPartitionsRDD [5699] run at <unknown>:0"]; } subgraph cluster12745 { label="WholeStageCodegen (1)"; 5700 [labelType="html" label="MapPartitionsRDD [5700] run at <unknown>:0"]; } subgraph cluster12759 { label="WholeStageCodegen (1)"; 5702 [labelType="html" label="MapPartitionsRDD [5702] toJavaRDD at <unknown>:0"]; } subgraph cluster12758 { label="Filter"; 5703 [labelType="html" label="MapPartitionsRDD [5703] toJavaRDD at <unknown>:0"]; } subgraph cluster12757 { label="Project"; 5704 [labelType="html" label="MapPartitionsRDD [5704] toJavaRDD at <unknown>:0"]; } subgraph cluster12754 { label="WholeStageCodegen (2)"; 5705 [labelType="html" label="MapPartitionsRDD [5705] toJavaRDD at <unknown>:0"]; } subgraph cluster12753 { label="Project"; 5706 [labelType="html" label="MapPartitionsRDD [5706] toJavaRDD at <unknown>:0"]; } subgraph cluster12752 { label="DeserializeToObject"; 5707 [labelType="html" label="MapPartitionsRDD [5707] toJavaRDD at <unknown>:0"]; } subgraph cluster12751 { label="MapPartitions"; 5708 [labelType="html" label="MapPartitionsRDD [5708] toJavaRDD at <unknown>:0"]; } subgraph cluster12761 { label="mapPartitions"; 5710 [labelType="html" label="MapPartitionsRDD [5710] toJavaRDD at <unknown>:0"]; } } 5697->5698; 5698->5699; 5699->5700; 5700->5701; 5701->5702; 5702->5703; 5703->5704; 5704->5705; 5705->5706; 5706->5707; 5707->5708; 5708->5709; 5709->5710; 5710->5711; }

Event Timeline

Enable zooming