processing-stream-kafka-raw-to-minio - Details for Stage 913 (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: 914

digraph G { subgraph clusterstage_913 { label="Stage 913"; 9602 [labelType="html" label="SQLExecutionRDD [9602] run at <unknown>:0"]; 9610 [labelType="html" label="SQLExecutionRDD [9610] toJavaRDD at <unknown>:0"]; 9612 [labelType="html" label="PythonRDD [9612] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster21480 { label="MicroBatchScan"; 9598 [labelType="html" label="DataSourceRDD [9598] run at <unknown>:0"]; 9599 [labelType="html" label="MapPartitionsRDD [9599] run at <unknown>:0"]; } subgraph cluster21479 { label="Project"; 9600 [labelType="html" label="MapPartitionsRDD [9600] run at <unknown>:0"]; } subgraph cluster21475 { label="WholeStageCodegen (1)"; 9601 [labelType="html" label="MapPartitionsRDD [9601] run at <unknown>:0"]; } subgraph cluster21489 { label="WholeStageCodegen (1)"; 9603 [labelType="html" label="MapPartitionsRDD [9603] toJavaRDD at <unknown>:0"]; } subgraph cluster21488 { label="Filter"; 9604 [labelType="html" label="MapPartitionsRDD [9604] toJavaRDD at <unknown>:0"]; } subgraph cluster21487 { label="Project"; 9605 [labelType="html" label="MapPartitionsRDD [9605] toJavaRDD at <unknown>:0"]; } subgraph cluster21484 { label="WholeStageCodegen (2)"; 9606 [labelType="html" label="MapPartitionsRDD [9606] toJavaRDD at <unknown>:0"]; } subgraph cluster21483 { label="Project"; 9607 [labelType="html" label="MapPartitionsRDD [9607] toJavaRDD at <unknown>:0"]; } subgraph cluster21482 { label="DeserializeToObject"; 9608 [labelType="html" label="MapPartitionsRDD [9608] toJavaRDD at <unknown>:0"]; } subgraph cluster21481 { label="MapPartitions"; 9609 [labelType="html" label="MapPartitionsRDD [9609] toJavaRDD at <unknown>:0"]; } subgraph cluster21491 { label="mapPartitions"; 9611 [labelType="html" label="MapPartitionsRDD [9611] toJavaRDD at <unknown>:0"]; } } 9598->9599; 9599->9600; 9600->9601; 9601->9602; 9602->9603; 9603->9604; 9604->9605; 9605->9606; 9606->9607; 9607->9608; 9608->9609; 9609->9610; 9610->9611; 9611->9612; }

Event Timeline

Enable zooming