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

digraph G { subgraph clusterstage_292 { label="Stage 292"; 3070 [labelType="html" label="SQLExecutionRDD [3070] run at <unknown>:0"]; 3078 [labelType="html" label="SQLExecutionRDD [3078] toJavaRDD at <unknown>:0"]; 3080 [labelType="html" label="PythonRDD [3080] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster6867 { label="MicroBatchScan"; 3066 [labelType="html" label="DataSourceRDD [3066] run at <unknown>:0"]; 3067 [labelType="html" label="MapPartitionsRDD [3067] run at <unknown>:0"]; } subgraph cluster6866 { label="Project"; 3068 [labelType="html" label="MapPartitionsRDD [3068] run at <unknown>:0"]; } subgraph cluster6862 { label="WholeStageCodegen (1)"; 3069 [labelType="html" label="MapPartitionsRDD [3069] run at <unknown>:0"]; } subgraph cluster6876 { label="WholeStageCodegen (1)"; 3071 [labelType="html" label="MapPartitionsRDD [3071] toJavaRDD at <unknown>:0"]; } subgraph cluster6875 { label="Filter"; 3072 [labelType="html" label="MapPartitionsRDD [3072] toJavaRDD at <unknown>:0"]; } subgraph cluster6874 { label="Project"; 3073 [labelType="html" label="MapPartitionsRDD [3073] toJavaRDD at <unknown>:0"]; } subgraph cluster6871 { label="WholeStageCodegen (2)"; 3074 [labelType="html" label="MapPartitionsRDD [3074] toJavaRDD at <unknown>:0"]; } subgraph cluster6870 { label="Project"; 3075 [labelType="html" label="MapPartitionsRDD [3075] toJavaRDD at <unknown>:0"]; } subgraph cluster6869 { label="DeserializeToObject"; 3076 [labelType="html" label="MapPartitionsRDD [3076] toJavaRDD at <unknown>:0"]; } subgraph cluster6868 { label="MapPartitions"; 3077 [labelType="html" label="MapPartitionsRDD [3077] toJavaRDD at <unknown>:0"]; } subgraph cluster6878 { label="mapPartitions"; 3079 [labelType="html" label="MapPartitionsRDD [3079] toJavaRDD at <unknown>:0"]; } } 3066->3067; 3067->3068; 3068->3069; 3069->3070; 3070->3071; 3071->3072; 3072->3073; 3073->3074; 3074->3075; 3075->3076; 3076->3077; 3077->3078; 3078->3079; 3079->3080; }

Event Timeline

Enable zooming