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

digraph G { subgraph clusterstage_1385 { label="Stage 1385"; 14558 [labelType="html" label="SQLExecutionRDD [14558] run at <unknown>:0"]; 14566 [labelType="html" label="SQLExecutionRDD [14566] toJavaRDD at <unknown>:0"]; 14568 [labelType="html" label="PythonRDD [14568] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster32572 { label="MicroBatchScan"; 14554 [labelType="html" label="DataSourceRDD [14554] run at <unknown>:0"]; 14555 [labelType="html" label="MapPartitionsRDD [14555] run at <unknown>:0"]; } subgraph cluster32571 { label="Project"; 14556 [labelType="html" label="MapPartitionsRDD [14556] run at <unknown>:0"]; } subgraph cluster32567 { label="WholeStageCodegen (1)"; 14557 [labelType="html" label="MapPartitionsRDD [14557] run at <unknown>:0"]; } subgraph cluster32581 { label="WholeStageCodegen (1)"; 14559 [labelType="html" label="MapPartitionsRDD [14559] toJavaRDD at <unknown>:0"]; } subgraph cluster32580 { label="Filter"; 14560 [labelType="html" label="MapPartitionsRDD [14560] toJavaRDD at <unknown>:0"]; } subgraph cluster32579 { label="Project"; 14561 [labelType="html" label="MapPartitionsRDD [14561] toJavaRDD at <unknown>:0"]; } subgraph cluster32576 { label="WholeStageCodegen (2)"; 14562 [labelType="html" label="MapPartitionsRDD [14562] toJavaRDD at <unknown>:0"]; } subgraph cluster32575 { label="Project"; 14563 [labelType="html" label="MapPartitionsRDD [14563] toJavaRDD at <unknown>:0"]; } subgraph cluster32574 { label="DeserializeToObject"; 14564 [labelType="html" label="MapPartitionsRDD [14564] toJavaRDD at <unknown>:0"]; } subgraph cluster32573 { label="MapPartitions"; 14565 [labelType="html" label="MapPartitionsRDD [14565] toJavaRDD at <unknown>:0"]; } subgraph cluster32583 { label="mapPartitions"; 14567 [labelType="html" label="MapPartitionsRDD [14567] toJavaRDD at <unknown>:0"]; } } 14554->14555; 14555->14556; 14556->14557; 14557->14558; 14558->14559; 14559->14560; 14560->14561; 14561->14562; 14562->14563; 14563->14564; 14564->14565; 14565->14566; 14566->14567; 14567->14568; }

Event Timeline

Enable zooming