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

digraph G { subgraph clusterstage_1220 { label="Stage 1220"; 12815 [labelType="html" label="SQLExecutionRDD [12815] run at <unknown>:0"]; 12829 [labelType="html" label="SQLExecutionRDD [12829] toJavaRDD at <unknown>:0"]; 12831 [labelType="html" label="PythonRDD [12831] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster28671 { label="MicroBatchScan"; 12811 [labelType="html" label="DataSourceRDD [12811] run at <unknown>:0"]; 12812 [labelType="html" label="MapPartitionsRDD [12812] run at <unknown>:0"]; } subgraph cluster28670 { label="Project"; 12813 [labelType="html" label="MapPartitionsRDD [12813] run at <unknown>:0"]; } subgraph cluster28666 { label="WholeStageCodegen (1)"; 12814 [labelType="html" label="MapPartitionsRDD [12814] run at <unknown>:0"]; } subgraph cluster28688 { label="WholeStageCodegen (1)"; 12822 [labelType="html" label="MapPartitionsRDD [12822] toJavaRDD at <unknown>:0"]; } subgraph cluster28687 { label="Filter"; 12823 [labelType="html" label="MapPartitionsRDD [12823] toJavaRDD at <unknown>:0"]; } subgraph cluster28686 { label="Project"; 12824 [labelType="html" label="MapPartitionsRDD [12824] toJavaRDD at <unknown>:0"]; } subgraph cluster28683 { label="WholeStageCodegen (2)"; 12825 [labelType="html" label="MapPartitionsRDD [12825] toJavaRDD at <unknown>:0"]; } subgraph cluster28682 { label="Project"; 12826 [labelType="html" label="MapPartitionsRDD [12826] toJavaRDD at <unknown>:0"]; } subgraph cluster28681 { label="DeserializeToObject"; 12827 [labelType="html" label="MapPartitionsRDD [12827] toJavaRDD at <unknown>:0"]; } subgraph cluster28680 { label="MapPartitions"; 12828 [labelType="html" label="MapPartitionsRDD [12828] toJavaRDD at <unknown>:0"]; } subgraph cluster28690 { label="mapPartitions"; 12830 [labelType="html" label="MapPartitionsRDD [12830] toJavaRDD at <unknown>:0"]; } } 12811->12812; 12812->12813; 12813->12814; 12814->12815; 12815->12822; 12822->12823; 12823->12824; 12824->12825; 12825->12826; 12826->12827; 12827->12828; 12828->12829; 12829->12830; 12830->12831; }

Event Timeline

Enable zooming