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

digraph G { subgraph clusterstage_1245 { label="Stage 1245"; 13088 [labelType="html" label="SQLExecutionRDD [13088] run at <unknown>:0"]; 13096 [labelType="html" label="SQLExecutionRDD [13096] toJavaRDD at <unknown>:0"]; 13098 [labelType="html" label="PythonRDD [13098] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster29282 { label="MicroBatchScan"; 13084 [labelType="html" label="DataSourceRDD [13084] run at <unknown>:0"]; 13085 [labelType="html" label="MapPartitionsRDD [13085] run at <unknown>:0"]; } subgraph cluster29281 { label="Project"; 13086 [labelType="html" label="MapPartitionsRDD [13086] run at <unknown>:0"]; } subgraph cluster29277 { label="WholeStageCodegen (1)"; 13087 [labelType="html" label="MapPartitionsRDD [13087] run at <unknown>:0"]; } subgraph cluster29291 { label="WholeStageCodegen (1)"; 13089 [labelType="html" label="MapPartitionsRDD [13089] toJavaRDD at <unknown>:0"]; } subgraph cluster29290 { label="Filter"; 13090 [labelType="html" label="MapPartitionsRDD [13090] toJavaRDD at <unknown>:0"]; } subgraph cluster29289 { label="Project"; 13091 [labelType="html" label="MapPartitionsRDD [13091] toJavaRDD at <unknown>:0"]; } subgraph cluster29286 { label="WholeStageCodegen (2)"; 13092 [labelType="html" label="MapPartitionsRDD [13092] toJavaRDD at <unknown>:0"]; } subgraph cluster29285 { label="Project"; 13093 [labelType="html" label="MapPartitionsRDD [13093] toJavaRDD at <unknown>:0"]; } subgraph cluster29284 { label="DeserializeToObject"; 13094 [labelType="html" label="MapPartitionsRDD [13094] toJavaRDD at <unknown>:0"]; } subgraph cluster29283 { label="MapPartitions"; 13095 [labelType="html" label="MapPartitionsRDD [13095] toJavaRDD at <unknown>:0"]; } subgraph cluster29293 { label="mapPartitions"; 13097 [labelType="html" label="MapPartitionsRDD [13097] toJavaRDD at <unknown>:0"]; } } 13084->13085; 13085->13086; 13086->13087; 13087->13088; 13088->13089; 13089->13090; 13090->13091; 13091->13092; 13092->13093; 13093->13094; 13094->13095; 13095->13096; 13096->13097; 13097->13098; }

Event Timeline

Enable zooming