processing-stream-kafka-raw-to-minio - Details for Stage 268 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 4
Input Size / Records: 0.0 B / 404
Associated Job Ids: 268

digraph G { subgraph clusterstage_268 { label="Stage 268"; 2818 [labelType="html" label="SQLExecutionRDD [2818] run at <unknown>:0"]; 2826 [labelType="html" label="SQLExecutionRDD [2826] toJavaRDD at <unknown>:0"]; 2828 [labelType="html" label="PythonRDD [2828] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster6303 { label="MicroBatchScan"; 2814 [labelType="html" label="DataSourceRDD [2814] run at <unknown>:0"]; 2815 [labelType="html" label="MapPartitionsRDD [2815] run at <unknown>:0"]; } subgraph cluster6302 { label="Project"; 2816 [labelType="html" label="MapPartitionsRDD [2816] run at <unknown>:0"]; } subgraph cluster6298 { label="WholeStageCodegen (1)"; 2817 [labelType="html" label="MapPartitionsRDD [2817] run at <unknown>:0"]; } subgraph cluster6312 { label="WholeStageCodegen (1)"; 2819 [labelType="html" label="MapPartitionsRDD [2819] toJavaRDD at <unknown>:0"]; } subgraph cluster6311 { label="Filter"; 2820 [labelType="html" label="MapPartitionsRDD [2820] toJavaRDD at <unknown>:0"]; } subgraph cluster6310 { label="Project"; 2821 [labelType="html" label="MapPartitionsRDD [2821] toJavaRDD at <unknown>:0"]; } subgraph cluster6307 { label="WholeStageCodegen (2)"; 2822 [labelType="html" label="MapPartitionsRDD [2822] toJavaRDD at <unknown>:0"]; } subgraph cluster6306 { label="Project"; 2823 [labelType="html" label="MapPartitionsRDD [2823] toJavaRDD at <unknown>:0"]; } subgraph cluster6305 { label="DeserializeToObject"; 2824 [labelType="html" label="MapPartitionsRDD [2824] toJavaRDD at <unknown>:0"]; } subgraph cluster6304 { label="MapPartitions"; 2825 [labelType="html" label="MapPartitionsRDD [2825] toJavaRDD at <unknown>:0"]; } subgraph cluster6314 { label="mapPartitions"; 2827 [labelType="html" label="MapPartitionsRDD [2827] toJavaRDD at <unknown>:0"]; } } 2814->2815; 2815->2816; 2816->2817; 2817->2818; 2818->2819; 2819->2820; 2820->2821; 2821->2822; 2822->2823; 2823->2824; 2824->2825; 2825->2826; 2826->2827; 2827->2828; }

Event Timeline

Enable zooming