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

digraph G { subgraph clusterstage_1601 { label="Stage 1601"; 16826 [labelType="html" label="SQLExecutionRDD [16826] run at <unknown>:0"]; 16834 [labelType="html" label="SQLExecutionRDD [16834] toJavaRDD at <unknown>:0"]; 16836 [labelType="html" label="PythonRDD [16836] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster37648 { label="MicroBatchScan"; 16822 [labelType="html" label="DataSourceRDD [16822] run at <unknown>:0"]; 16823 [labelType="html" label="MapPartitionsRDD [16823] run at <unknown>:0"]; } subgraph cluster37647 { label="Project"; 16824 [labelType="html" label="MapPartitionsRDD [16824] run at <unknown>:0"]; } subgraph cluster37643 { label="WholeStageCodegen (1)"; 16825 [labelType="html" label="MapPartitionsRDD [16825] run at <unknown>:0"]; } subgraph cluster37657 { label="WholeStageCodegen (1)"; 16827 [labelType="html" label="MapPartitionsRDD [16827] toJavaRDD at <unknown>:0"]; } subgraph cluster37656 { label="Filter"; 16828 [labelType="html" label="MapPartitionsRDD [16828] toJavaRDD at <unknown>:0"]; } subgraph cluster37655 { label="Project"; 16829 [labelType="html" label="MapPartitionsRDD [16829] toJavaRDD at <unknown>:0"]; } subgraph cluster37652 { label="WholeStageCodegen (2)"; 16830 [labelType="html" label="MapPartitionsRDD [16830] toJavaRDD at <unknown>:0"]; } subgraph cluster37651 { label="Project"; 16831 [labelType="html" label="MapPartitionsRDD [16831] toJavaRDD at <unknown>:0"]; } subgraph cluster37650 { label="DeserializeToObject"; 16832 [labelType="html" label="MapPartitionsRDD [16832] toJavaRDD at <unknown>:0"]; } subgraph cluster37649 { label="MapPartitions"; 16833 [labelType="html" label="MapPartitionsRDD [16833] toJavaRDD at <unknown>:0"]; } subgraph cluster37659 { label="mapPartitions"; 16835 [labelType="html" label="MapPartitionsRDD [16835] toJavaRDD at <unknown>:0"]; } } 16822->16823; 16823->16824; 16824->16825; 16825->16826; 16826->16827; 16827->16828; 16828->16829; 16829->16830; 16830->16831; 16831->16832; 16832->16833; 16833->16834; 16834->16835; 16835->16836; }

Event Timeline

Enable zooming