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

digraph G { subgraph clusterstage_1288 { label="Stage 1288"; 13528 [labelType="html" label="SQLExecutionRDD [13528] run at <unknown>:0"]; 13536 [labelType="html" label="SQLExecutionRDD [13536] toJavaRDD at <unknown>:0"]; 13538 [labelType="html" label="PythonRDD [13538] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster30273 { label="MicroBatchScan"; 13524 [labelType="html" label="DataSourceRDD [13524] run at <unknown>:0"]; 13525 [labelType="html" label="MapPartitionsRDD [13525] run at <unknown>:0"]; } subgraph cluster30272 { label="Project"; 13526 [labelType="html" label="MapPartitionsRDD [13526] run at <unknown>:0"]; } subgraph cluster30268 { label="WholeStageCodegen (1)"; 13527 [labelType="html" label="MapPartitionsRDD [13527] run at <unknown>:0"]; } subgraph cluster30282 { label="WholeStageCodegen (1)"; 13529 [labelType="html" label="MapPartitionsRDD [13529] toJavaRDD at <unknown>:0"]; } subgraph cluster30281 { label="Filter"; 13530 [labelType="html" label="MapPartitionsRDD [13530] toJavaRDD at <unknown>:0"]; } subgraph cluster30280 { label="Project"; 13531 [labelType="html" label="MapPartitionsRDD [13531] toJavaRDD at <unknown>:0"]; } subgraph cluster30277 { label="WholeStageCodegen (2)"; 13532 [labelType="html" label="MapPartitionsRDD [13532] toJavaRDD at <unknown>:0"]; } subgraph cluster30276 { label="Project"; 13533 [labelType="html" label="MapPartitionsRDD [13533] toJavaRDD at <unknown>:0"]; } subgraph cluster30275 { label="DeserializeToObject"; 13534 [labelType="html" label="MapPartitionsRDD [13534] toJavaRDD at <unknown>:0"]; } subgraph cluster30274 { label="MapPartitions"; 13535 [labelType="html" label="MapPartitionsRDD [13535] toJavaRDD at <unknown>:0"]; } subgraph cluster30284 { label="mapPartitions"; 13537 [labelType="html" label="MapPartitionsRDD [13537] toJavaRDD at <unknown>:0"]; } } 13524->13525; 13525->13526; 13526->13527; 13527->13528; 13528->13529; 13529->13530; 13530->13531; 13531->13532; 13532->13533; 13533->13534; 13534->13535; 13535->13536; 13536->13537; 13537->13538; }

Event Timeline

Enable zooming