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

digraph G { subgraph clusterstage_291 { label="Stage 291"; 3049 [labelType="html" label="SQLExecutionRDD [3049] run at <unknown>:0"]; 3063 [labelType="html" label="SQLExecutionRDD [3063] toJavaRDD at <unknown>:0"]; 3065 [labelType="html" label="PythonRDD [3065] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster6820 { label="MicroBatchScan"; 3045 [labelType="html" label="DataSourceRDD [3045] run at <unknown>:0"]; 3046 [labelType="html" label="MapPartitionsRDD [3046] run at <unknown>:0"]; } subgraph cluster6819 { label="Project"; 3047 [labelType="html" label="MapPartitionsRDD [3047] run at <unknown>:0"]; } subgraph cluster6815 { label="WholeStageCodegen (1)"; 3048 [labelType="html" label="MapPartitionsRDD [3048] run at <unknown>:0"]; } subgraph cluster6837 { label="WholeStageCodegen (1)"; 3056 [labelType="html" label="MapPartitionsRDD [3056] toJavaRDD at <unknown>:0"]; } subgraph cluster6836 { label="Filter"; 3057 [labelType="html" label="MapPartitionsRDD [3057] toJavaRDD at <unknown>:0"]; } subgraph cluster6835 { label="Project"; 3058 [labelType="html" label="MapPartitionsRDD [3058] toJavaRDD at <unknown>:0"]; } subgraph cluster6832 { label="WholeStageCodegen (2)"; 3059 [labelType="html" label="MapPartitionsRDD [3059] toJavaRDD at <unknown>:0"]; } subgraph cluster6831 { label="Project"; 3060 [labelType="html" label="MapPartitionsRDD [3060] toJavaRDD at <unknown>:0"]; } subgraph cluster6830 { label="DeserializeToObject"; 3061 [labelType="html" label="MapPartitionsRDD [3061] toJavaRDD at <unknown>:0"]; } subgraph cluster6829 { label="MapPartitions"; 3062 [labelType="html" label="MapPartitionsRDD [3062] toJavaRDD at <unknown>:0"]; } subgraph cluster6839 { label="mapPartitions"; 3064 [labelType="html" label="MapPartitionsRDD [3064] toJavaRDD at <unknown>:0"]; } } 3045->3046; 3046->3047; 3047->3048; 3048->3049; 3049->3056; 3056->3057; 3057->3058; 3058->3059; 3059->3060; 3060->3061; 3061->3062; 3062->3063; 3063->3064; 3064->3065; }

Event Timeline

Enable zooming