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

digraph G { subgraph clusterstage_906 { label="Stage 906"; 9518 [labelType="html" label="SQLExecutionRDD [9518] run at <unknown>:0"]; 9532 [labelType="html" label="SQLExecutionRDD [9532] toJavaRDD at <unknown>:0"]; 9534 [labelType="html" label="PythonRDD [9534] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster21292 { label="MicroBatchScan"; 9514 [labelType="html" label="DataSourceRDD [9514] run at <unknown>:0"]; 9515 [labelType="html" label="MapPartitionsRDD [9515] run at <unknown>:0"]; } subgraph cluster21291 { label="Project"; 9516 [labelType="html" label="MapPartitionsRDD [9516] run at <unknown>:0"]; } subgraph cluster21287 { label="WholeStageCodegen (1)"; 9517 [labelType="html" label="MapPartitionsRDD [9517] run at <unknown>:0"]; } subgraph cluster21309 { label="WholeStageCodegen (1)"; 9525 [labelType="html" label="MapPartitionsRDD [9525] toJavaRDD at <unknown>:0"]; } subgraph cluster21308 { label="Filter"; 9526 [labelType="html" label="MapPartitionsRDD [9526] toJavaRDD at <unknown>:0"]; } subgraph cluster21307 { label="Project"; 9527 [labelType="html" label="MapPartitionsRDD [9527] toJavaRDD at <unknown>:0"]; } subgraph cluster21304 { label="WholeStageCodegen (2)"; 9528 [labelType="html" label="MapPartitionsRDD [9528] toJavaRDD at <unknown>:0"]; } subgraph cluster21303 { label="Project"; 9529 [labelType="html" label="MapPartitionsRDD [9529] toJavaRDD at <unknown>:0"]; } subgraph cluster21302 { label="DeserializeToObject"; 9530 [labelType="html" label="MapPartitionsRDD [9530] toJavaRDD at <unknown>:0"]; } subgraph cluster21301 { label="MapPartitions"; 9531 [labelType="html" label="MapPartitionsRDD [9531] toJavaRDD at <unknown>:0"]; } subgraph cluster21311 { label="mapPartitions"; 9533 [labelType="html" label="MapPartitionsRDD [9533] toJavaRDD at <unknown>:0"]; } } 9514->9515; 9515->9516; 9516->9517; 9517->9518; 9518->9525; 9525->9526; 9526->9527; 9527->9528; 9528->9529; 9529->9530; 9530->9531; 9531->9532; 9532->9533; 9533->9534; }

Event Timeline

Enable zooming