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

digraph G { subgraph clusterstage_862 { label="Stage 862"; 9055 [labelType="html" label="SQLExecutionRDD [9055] run at <unknown>:0"]; 9063 [labelType="html" label="SQLExecutionRDD [9063] toJavaRDD at <unknown>:0"]; 9065 [labelType="html" label="PythonRDD [9065] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster20262 { label="MicroBatchScan"; 9051 [labelType="html" label="DataSourceRDD [9051] run at <unknown>:0"]; 9052 [labelType="html" label="MapPartitionsRDD [9052] run at <unknown>:0"]; } subgraph cluster20261 { label="Project"; 9053 [labelType="html" label="MapPartitionsRDD [9053] run at <unknown>:0"]; } subgraph cluster20257 { label="WholeStageCodegen (1)"; 9054 [labelType="html" label="MapPartitionsRDD [9054] run at <unknown>:0"]; } subgraph cluster20271 { label="WholeStageCodegen (1)"; 9056 [labelType="html" label="MapPartitionsRDD [9056] toJavaRDD at <unknown>:0"]; } subgraph cluster20270 { label="Filter"; 9057 [labelType="html" label="MapPartitionsRDD [9057] toJavaRDD at <unknown>:0"]; } subgraph cluster20269 { label="Project"; 9058 [labelType="html" label="MapPartitionsRDD [9058] toJavaRDD at <unknown>:0"]; } subgraph cluster20266 { label="WholeStageCodegen (2)"; 9059 [labelType="html" label="MapPartitionsRDD [9059] toJavaRDD at <unknown>:0"]; } subgraph cluster20265 { label="Project"; 9060 [labelType="html" label="MapPartitionsRDD [9060] toJavaRDD at <unknown>:0"]; } subgraph cluster20264 { label="DeserializeToObject"; 9061 [labelType="html" label="MapPartitionsRDD [9061] toJavaRDD at <unknown>:0"]; } subgraph cluster20263 { label="MapPartitions"; 9062 [labelType="html" label="MapPartitionsRDD [9062] toJavaRDD at <unknown>:0"]; } subgraph cluster20273 { label="mapPartitions"; 9064 [labelType="html" label="MapPartitionsRDD [9064] toJavaRDD at <unknown>:0"]; } } 9051->9052; 9052->9053; 9053->9054; 9054->9055; 9055->9056; 9056->9057; 9057->9058; 9058->9059; 9059->9060; 9060->9061; 9061->9062; 9062->9063; 9063->9064; 9064->9065; }

Event Timeline

Enable zooming