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

digraph G { subgraph clusterstage_164 { label="Stage 164"; 1726 [labelType="html" label="SQLExecutionRDD [1726] run at <unknown>:0"]; 1734 [labelType="html" label="SQLExecutionRDD [1734] toJavaRDD at <unknown>:0"]; 1736 [labelType="html" label="PythonRDD [1736] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster3859 { label="MicroBatchScan"; 1722 [labelType="html" label="DataSourceRDD [1722] run at <unknown>:0"]; 1723 [labelType="html" label="MapPartitionsRDD [1723] run at <unknown>:0"]; } subgraph cluster3858 { label="Project"; 1724 [labelType="html" label="MapPartitionsRDD [1724] run at <unknown>:0"]; } subgraph cluster3854 { label="WholeStageCodegen (1)"; 1725 [labelType="html" label="MapPartitionsRDD [1725] run at <unknown>:0"]; } subgraph cluster3868 { label="WholeStageCodegen (1)"; 1727 [labelType="html" label="MapPartitionsRDD [1727] toJavaRDD at <unknown>:0"]; } subgraph cluster3867 { label="Filter"; 1728 [labelType="html" label="MapPartitionsRDD [1728] toJavaRDD at <unknown>:0"]; } subgraph cluster3866 { label="Project"; 1729 [labelType="html" label="MapPartitionsRDD [1729] toJavaRDD at <unknown>:0"]; } subgraph cluster3863 { label="WholeStageCodegen (2)"; 1730 [labelType="html" label="MapPartitionsRDD [1730] toJavaRDD at <unknown>:0"]; } subgraph cluster3862 { label="Project"; 1731 [labelType="html" label="MapPartitionsRDD [1731] toJavaRDD at <unknown>:0"]; } subgraph cluster3861 { label="DeserializeToObject"; 1732 [labelType="html" label="MapPartitionsRDD [1732] toJavaRDD at <unknown>:0"]; } subgraph cluster3860 { label="MapPartitions"; 1733 [labelType="html" label="MapPartitionsRDD [1733] toJavaRDD at <unknown>:0"]; } subgraph cluster3870 { label="mapPartitions"; 1735 [labelType="html" label="MapPartitionsRDD [1735] toJavaRDD at <unknown>:0"]; } } 1722->1723; 1723->1724; 1724->1725; 1725->1726; 1726->1727; 1727->1728; 1728->1729; 1729->1730; 1730->1731; 1731->1732; 1732->1733; 1733->1734; 1734->1735; 1735->1736; }

Event Timeline

Enable zooming