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

digraph G { subgraph clusterstage_305 { label="Stage 305"; 3202 [labelType="html" label="SQLExecutionRDD [3202] run at <unknown>:0"]; 3210 [labelType="html" label="SQLExecutionRDD [3210] toJavaRDD at <unknown>:0"]; 3212 [labelType="html" label="PythonRDD [3212] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster7157 { label="MicroBatchScan"; 3198 [labelType="html" label="DataSourceRDD [3198] run at <unknown>:0"]; 3199 [labelType="html" label="MapPartitionsRDD [3199] run at <unknown>:0"]; } subgraph cluster7156 { label="Project"; 3200 [labelType="html" label="MapPartitionsRDD [3200] run at <unknown>:0"]; } subgraph cluster7152 { label="WholeStageCodegen (1)"; 3201 [labelType="html" label="MapPartitionsRDD [3201] run at <unknown>:0"]; } subgraph cluster7166 { label="WholeStageCodegen (1)"; 3203 [labelType="html" label="MapPartitionsRDD [3203] toJavaRDD at <unknown>:0"]; } subgraph cluster7165 { label="Filter"; 3204 [labelType="html" label="MapPartitionsRDD [3204] toJavaRDD at <unknown>:0"]; } subgraph cluster7164 { label="Project"; 3205 [labelType="html" label="MapPartitionsRDD [3205] toJavaRDD at <unknown>:0"]; } subgraph cluster7161 { label="WholeStageCodegen (2)"; 3206 [labelType="html" label="MapPartitionsRDD [3206] toJavaRDD at <unknown>:0"]; } subgraph cluster7160 { label="Project"; 3207 [labelType="html" label="MapPartitionsRDD [3207] toJavaRDD at <unknown>:0"]; } subgraph cluster7159 { label="DeserializeToObject"; 3208 [labelType="html" label="MapPartitionsRDD [3208] toJavaRDD at <unknown>:0"]; } subgraph cluster7158 { label="MapPartitions"; 3209 [labelType="html" label="MapPartitionsRDD [3209] toJavaRDD at <unknown>:0"]; } subgraph cluster7168 { label="mapPartitions"; 3211 [labelType="html" label="MapPartitionsRDD [3211] toJavaRDD at <unknown>:0"]; } } 3198->3199; 3199->3200; 3200->3201; 3201->3202; 3202->3203; 3203->3204; 3204->3205; 3205->3206; 3206->3207; 3207->3208; 3208->3209; 3209->3210; 3210->3211; 3211->3212; }

Event Timeline

Enable zooming