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

digraph G { subgraph clusterstage_327 { label="Stage 327"; 3433 [labelType="html" label="SQLExecutionRDD [3433] run at <unknown>:0"]; 3441 [labelType="html" label="SQLExecutionRDD [3441] toJavaRDD at <unknown>:0"]; 3443 [labelType="html" label="PythonRDD [3443] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster7674 { label="MicroBatchScan"; 3429 [labelType="html" label="DataSourceRDD [3429] run at <unknown>:0"]; 3430 [labelType="html" label="MapPartitionsRDD [3430] run at <unknown>:0"]; } subgraph cluster7673 { label="Project"; 3431 [labelType="html" label="MapPartitionsRDD [3431] run at <unknown>:0"]; } subgraph cluster7669 { label="WholeStageCodegen (1)"; 3432 [labelType="html" label="MapPartitionsRDD [3432] run at <unknown>:0"]; } subgraph cluster7683 { label="WholeStageCodegen (1)"; 3434 [labelType="html" label="MapPartitionsRDD [3434] toJavaRDD at <unknown>:0"]; } subgraph cluster7682 { label="Filter"; 3435 [labelType="html" label="MapPartitionsRDD [3435] toJavaRDD at <unknown>:0"]; } subgraph cluster7681 { label="Project"; 3436 [labelType="html" label="MapPartitionsRDD [3436] toJavaRDD at <unknown>:0"]; } subgraph cluster7678 { label="WholeStageCodegen (2)"; 3437 [labelType="html" label="MapPartitionsRDD [3437] toJavaRDD at <unknown>:0"]; } subgraph cluster7677 { label="Project"; 3438 [labelType="html" label="MapPartitionsRDD [3438] toJavaRDD at <unknown>:0"]; } subgraph cluster7676 { label="DeserializeToObject"; 3439 [labelType="html" label="MapPartitionsRDD [3439] toJavaRDD at <unknown>:0"]; } subgraph cluster7675 { label="MapPartitions"; 3440 [labelType="html" label="MapPartitionsRDD [3440] toJavaRDD at <unknown>:0"]; } subgraph cluster7685 { label="mapPartitions"; 3442 [labelType="html" label="MapPartitionsRDD [3442] toJavaRDD at <unknown>:0"]; } } 3429->3430; 3430->3431; 3431->3432; 3432->3433; 3433->3434; 3434->3435; 3435->3436; 3436->3437; 3437->3438; 3438->3439; 3439->3440; 3440->3441; 3441->3442; 3442->3443; }

Event Timeline

Enable zooming