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

digraph G { subgraph clusterstage_302 { label="Stage 302"; 3175 [labelType="html" label="SQLExecutionRDD [3175] run at <unknown>:0"]; 3183 [labelType="html" label="SQLExecutionRDD [3183] toJavaRDD at <unknown>:0"]; 3185 [labelType="html" label="PythonRDD [3185] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster7102 { label="MicroBatchScan"; 3171 [labelType="html" label="DataSourceRDD [3171] run at <unknown>:0"]; 3172 [labelType="html" label="MapPartitionsRDD [3172] run at <unknown>:0"]; } subgraph cluster7101 { label="Project"; 3173 [labelType="html" label="MapPartitionsRDD [3173] run at <unknown>:0"]; } subgraph cluster7097 { label="WholeStageCodegen (1)"; 3174 [labelType="html" label="MapPartitionsRDD [3174] run at <unknown>:0"]; } subgraph cluster7111 { label="WholeStageCodegen (1)"; 3176 [labelType="html" label="MapPartitionsRDD [3176] toJavaRDD at <unknown>:0"]; } subgraph cluster7110 { label="Filter"; 3177 [labelType="html" label="MapPartitionsRDD [3177] toJavaRDD at <unknown>:0"]; } subgraph cluster7109 { label="Project"; 3178 [labelType="html" label="MapPartitionsRDD [3178] toJavaRDD at <unknown>:0"]; } subgraph cluster7106 { label="WholeStageCodegen (2)"; 3179 [labelType="html" label="MapPartitionsRDD [3179] toJavaRDD at <unknown>:0"]; } subgraph cluster7105 { label="Project"; 3180 [labelType="html" label="MapPartitionsRDD [3180] toJavaRDD at <unknown>:0"]; } subgraph cluster7104 { label="DeserializeToObject"; 3181 [labelType="html" label="MapPartitionsRDD [3181] toJavaRDD at <unknown>:0"]; } subgraph cluster7103 { label="MapPartitions"; 3182 [labelType="html" label="MapPartitionsRDD [3182] toJavaRDD at <unknown>:0"]; } subgraph cluster7113 { label="mapPartitions"; 3184 [labelType="html" label="MapPartitionsRDD [3184] toJavaRDD at <unknown>:0"]; } } 3171->3172; 3172->3173; 3173->3174; 3174->3175; 3175->3176; 3176->3177; 3177->3178; 3178->3179; 3179->3180; 3180->3181; 3181->3182; 3182->3183; 3183->3184; 3184->3185; }

Event Timeline

Enable zooming