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

digraph G { subgraph clusterstage_814 { label="Stage 814"; 8551 [labelType="html" label="SQLExecutionRDD [8551] run at <unknown>:0"]; 8559 [labelType="html" label="SQLExecutionRDD [8559] toJavaRDD at <unknown>:0"]; 8561 [labelType="html" label="PythonRDD [8561] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster19134 { label="MicroBatchScan"; 8547 [labelType="html" label="DataSourceRDD [8547] run at <unknown>:0"]; 8548 [labelType="html" label="MapPartitionsRDD [8548] run at <unknown>:0"]; } subgraph cluster19133 { label="Project"; 8549 [labelType="html" label="MapPartitionsRDD [8549] run at <unknown>:0"]; } subgraph cluster19129 { label="WholeStageCodegen (1)"; 8550 [labelType="html" label="MapPartitionsRDD [8550] run at <unknown>:0"]; } subgraph cluster19143 { label="WholeStageCodegen (1)"; 8552 [labelType="html" label="MapPartitionsRDD [8552] toJavaRDD at <unknown>:0"]; } subgraph cluster19142 { label="Filter"; 8553 [labelType="html" label="MapPartitionsRDD [8553] toJavaRDD at <unknown>:0"]; } subgraph cluster19141 { label="Project"; 8554 [labelType="html" label="MapPartitionsRDD [8554] toJavaRDD at <unknown>:0"]; } subgraph cluster19138 { label="WholeStageCodegen (2)"; 8555 [labelType="html" label="MapPartitionsRDD [8555] toJavaRDD at <unknown>:0"]; } subgraph cluster19137 { label="Project"; 8556 [labelType="html" label="MapPartitionsRDD [8556] toJavaRDD at <unknown>:0"]; } subgraph cluster19136 { label="DeserializeToObject"; 8557 [labelType="html" label="MapPartitionsRDD [8557] toJavaRDD at <unknown>:0"]; } subgraph cluster19135 { label="MapPartitions"; 8558 [labelType="html" label="MapPartitionsRDD [8558] toJavaRDD at <unknown>:0"]; } subgraph cluster19145 { label="mapPartitions"; 8560 [labelType="html" label="MapPartitionsRDD [8560] toJavaRDD at <unknown>:0"]; } } 8547->8548; 8548->8549; 8549->8550; 8550->8551; 8551->8552; 8552->8553; 8553->8554; 8554->8555; 8555->8556; 8556->8557; 8557->8558; 8558->8559; 8559->8560; 8560->8561; }

Event Timeline

Enable zooming