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

digraph G { subgraph clusterstage_1784 { label="Stage 1784"; 18736 [labelType="html" label="SQLExecutionRDD [18736] run at <unknown>:0"]; 18744 [labelType="html" label="SQLExecutionRDD [18744] toJavaRDD at <unknown>:0"]; 18746 [labelType="html" label="PythonRDD [18746] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster41929 { label="MicroBatchScan"; 18732 [labelType="html" label="DataSourceRDD [18732] run at <unknown>:0"]; 18733 [labelType="html" label="MapPartitionsRDD [18733] run at <unknown>:0"]; } subgraph cluster41928 { label="Project"; 18734 [labelType="html" label="MapPartitionsRDD [18734] run at <unknown>:0"]; } subgraph cluster41924 { label="WholeStageCodegen (1)"; 18735 [labelType="html" label="MapPartitionsRDD [18735] run at <unknown>:0"]; } subgraph cluster41938 { label="WholeStageCodegen (1)"; 18737 [labelType="html" label="MapPartitionsRDD [18737] toJavaRDD at <unknown>:0"]; } subgraph cluster41937 { label="Filter"; 18738 [labelType="html" label="MapPartitionsRDD [18738] toJavaRDD at <unknown>:0"]; } subgraph cluster41936 { label="Project"; 18739 [labelType="html" label="MapPartitionsRDD [18739] toJavaRDD at <unknown>:0"]; } subgraph cluster41933 { label="WholeStageCodegen (2)"; 18740 [labelType="html" label="MapPartitionsRDD [18740] toJavaRDD at <unknown>:0"]; } subgraph cluster41932 { label="Project"; 18741 [labelType="html" label="MapPartitionsRDD [18741] toJavaRDD at <unknown>:0"]; } subgraph cluster41931 { label="DeserializeToObject"; 18742 [labelType="html" label="MapPartitionsRDD [18742] toJavaRDD at <unknown>:0"]; } subgraph cluster41930 { label="MapPartitions"; 18743 [labelType="html" label="MapPartitionsRDD [18743] toJavaRDD at <unknown>:0"]; } subgraph cluster41940 { label="mapPartitions"; 18745 [labelType="html" label="MapPartitionsRDD [18745] toJavaRDD at <unknown>:0"]; } } 18732->18733; 18733->18734; 18734->18735; 18735->18736; 18736->18737; 18737->18738; 18738->18739; 18739->18740; 18740->18741; 18741->18742; 18742->18743; 18743->18744; 18744->18745; 18745->18746; }

Event Timeline

Enable zooming