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

digraph G { subgraph clusterstage_812 { label="Stage 812"; 8530 [labelType="html" label="SQLExecutionRDD [8530] run at <unknown>:0"]; 8538 [labelType="html" label="SQLExecutionRDD [8538] toJavaRDD at <unknown>:0"]; 8540 [labelType="html" label="PythonRDD [8540] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster19087 { label="MicroBatchScan"; 8526 [labelType="html" label="DataSourceRDD [8526] run at <unknown>:0"]; 8527 [labelType="html" label="MapPartitionsRDD [8527] run at <unknown>:0"]; } subgraph cluster19086 { label="Project"; 8528 [labelType="html" label="MapPartitionsRDD [8528] run at <unknown>:0"]; } subgraph cluster19082 { label="WholeStageCodegen (1)"; 8529 [labelType="html" label="MapPartitionsRDD [8529] run at <unknown>:0"]; } subgraph cluster19096 { label="WholeStageCodegen (1)"; 8531 [labelType="html" label="MapPartitionsRDD [8531] toJavaRDD at <unknown>:0"]; } subgraph cluster19095 { label="Filter"; 8532 [labelType="html" label="MapPartitionsRDD [8532] toJavaRDD at <unknown>:0"]; } subgraph cluster19094 { label="Project"; 8533 [labelType="html" label="MapPartitionsRDD [8533] toJavaRDD at <unknown>:0"]; } subgraph cluster19091 { label="WholeStageCodegen (2)"; 8534 [labelType="html" label="MapPartitionsRDD [8534] toJavaRDD at <unknown>:0"]; } subgraph cluster19090 { label="Project"; 8535 [labelType="html" label="MapPartitionsRDD [8535] toJavaRDD at <unknown>:0"]; } subgraph cluster19089 { label="DeserializeToObject"; 8536 [labelType="html" label="MapPartitionsRDD [8536] toJavaRDD at <unknown>:0"]; } subgraph cluster19088 { label="MapPartitions"; 8537 [labelType="html" label="MapPartitionsRDD [8537] toJavaRDD at <unknown>:0"]; } subgraph cluster19098 { label="mapPartitions"; 8539 [labelType="html" label="MapPartitionsRDD [8539] toJavaRDD at <unknown>:0"]; } } 8526->8527; 8527->8528; 8528->8529; 8529->8530; 8530->8531; 8531->8532; 8532->8533; 8533->8534; 8534->8535; 8535->8536; 8536->8537; 8537->8538; 8538->8539; 8539->8540; }

Event Timeline

Enable zooming