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

digraph G { subgraph clusterstage_416 { label="Stage 416"; 4372 [labelType="html" label="SQLExecutionRDD [4372] run at <unknown>:0"]; 4380 [labelType="html" label="SQLExecutionRDD [4380] toJavaRDD at <unknown>:0"]; 4382 [labelType="html" label="PythonRDD [4382] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster9781 { label="MicroBatchScan"; 4368 [labelType="html" label="DataSourceRDD [4368] run at <unknown>:0"]; 4369 [labelType="html" label="MapPartitionsRDD [4369] run at <unknown>:0"]; } subgraph cluster9780 { label="Project"; 4370 [labelType="html" label="MapPartitionsRDD [4370] run at <unknown>:0"]; } subgraph cluster9776 { label="WholeStageCodegen (1)"; 4371 [labelType="html" label="MapPartitionsRDD [4371] run at <unknown>:0"]; } subgraph cluster9790 { label="WholeStageCodegen (1)"; 4373 [labelType="html" label="MapPartitionsRDD [4373] toJavaRDD at <unknown>:0"]; } subgraph cluster9789 { label="Filter"; 4374 [labelType="html" label="MapPartitionsRDD [4374] toJavaRDD at <unknown>:0"]; } subgraph cluster9788 { label="Project"; 4375 [labelType="html" label="MapPartitionsRDD [4375] toJavaRDD at <unknown>:0"]; } subgraph cluster9785 { label="WholeStageCodegen (2)"; 4376 [labelType="html" label="MapPartitionsRDD [4376] toJavaRDD at <unknown>:0"]; } subgraph cluster9784 { label="Project"; 4377 [labelType="html" label="MapPartitionsRDD [4377] toJavaRDD at <unknown>:0"]; } subgraph cluster9783 { label="DeserializeToObject"; 4378 [labelType="html" label="MapPartitionsRDD [4378] toJavaRDD at <unknown>:0"]; } subgraph cluster9782 { label="MapPartitions"; 4379 [labelType="html" label="MapPartitionsRDD [4379] toJavaRDD at <unknown>:0"]; } subgraph cluster9792 { label="mapPartitions"; 4381 [labelType="html" label="MapPartitionsRDD [4381] toJavaRDD at <unknown>:0"]; } } 4368->4369; 4369->4370; 4370->4371; 4371->4372; 4372->4373; 4373->4374; 4374->4375; 4375->4376; 4376->4377; 4377->4378; 4378->4379; 4379->4380; 4380->4381; 4381->4382; }

Event Timeline

Enable zooming