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

digraph G { subgraph clusterstage_167 { label="Stage 167"; 1747 [labelType="html" label="SQLExecutionRDD [1747] run at <unknown>:0"]; 1761 [labelType="html" label="SQLExecutionRDD [1761] toJavaRDD at <unknown>:0"]; 1763 [labelType="html" label="PythonRDD [1763] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster3906 { label="MicroBatchScan"; 1743 [labelType="html" label="DataSourceRDD [1743] run at <unknown>:0"]; 1744 [labelType="html" label="MapPartitionsRDD [1744] run at <unknown>:0"]; } subgraph cluster3905 { label="Project"; 1745 [labelType="html" label="MapPartitionsRDD [1745] run at <unknown>:0"]; } subgraph cluster3901 { label="WholeStageCodegen (1)"; 1746 [labelType="html" label="MapPartitionsRDD [1746] run at <unknown>:0"]; } subgraph cluster3923 { label="WholeStageCodegen (1)"; 1754 [labelType="html" label="MapPartitionsRDD [1754] toJavaRDD at <unknown>:0"]; } subgraph cluster3922 { label="Filter"; 1755 [labelType="html" label="MapPartitionsRDD [1755] toJavaRDD at <unknown>:0"]; } subgraph cluster3921 { label="Project"; 1756 [labelType="html" label="MapPartitionsRDD [1756] toJavaRDD at <unknown>:0"]; } subgraph cluster3918 { label="WholeStageCodegen (2)"; 1757 [labelType="html" label="MapPartitionsRDD [1757] toJavaRDD at <unknown>:0"]; } subgraph cluster3917 { label="Project"; 1758 [labelType="html" label="MapPartitionsRDD [1758] toJavaRDD at <unknown>:0"]; } subgraph cluster3916 { label="DeserializeToObject"; 1759 [labelType="html" label="MapPartitionsRDD [1759] toJavaRDD at <unknown>:0"]; } subgraph cluster3915 { label="MapPartitions"; 1760 [labelType="html" label="MapPartitionsRDD [1760] toJavaRDD at <unknown>:0"]; } subgraph cluster3925 { label="mapPartitions"; 1762 [labelType="html" label="MapPartitionsRDD [1762] toJavaRDD at <unknown>:0"]; } } 1743->1744; 1744->1745; 1745->1746; 1746->1747; 1747->1754; 1754->1755; 1755->1756; 1756->1757; 1757->1758; 1758->1759; 1759->1760; 1760->1761; 1761->1762; 1762->1763; }

Event Timeline

Enable zooming